Johan Andrén
fb39ac1a9c
Tests for EventSourced remember entities shard store ( #29177 )
...
* Tests for EventSourced remember entities shard store
* Move the migration event adapter to a better place and mention in docs.
2020-06-04 09:54:28 +02:00
Christopher Batey
eb923bbbe1
Move coordinator state and remembered entities next to each other ( #29173 )
...
* Fix docs on how to passivate
* Remove 10000 limitation of remembered entities
2020-06-03 11:55:51 +01:00
Christopher Batey
870eef540a
Improve remember entities docs ( #29136 )
2020-05-27 15:50:55 +01:00
Christopher Batey
b463a1adbd
Merge master into re feature branch ( #29135 )
...
* Merge master into feature branch
* Formatting
* Remove redundant fixme
* Remove files that snuck in
* Fix backoff supervisor test
2020-05-27 12:50:53 +01:00
Patrik Nordwall
3deffc8de2
Harden ShardCoordinator state replication, #28856 ( #28895 ) ( #29094 )
...
* Possibility to prefer oldest in ddata writes and reads
* enabled for Cluster Sharding
* New ReadMajorityPlus and WriteMajorityPlus
* used by Cluster Sharding, with configuration
* also possible to define ReadAll in config
(cherry picked from commit 4ba835d328
2020-05-20 07:34:22 +01:00
Christopher Batey
dba6eec460
Migration from persistent shard coordinator to ddata with eventsource… ( #29058 )
...
* Migration from persistent shard coordinator to ddata with eventsourced remembered entities
* Fix bin compat in typed sharding
* Add log capturing
* Java API for nested case objects in typed sharding settings
* Starting some docs for remembering entities store
* Snapshot and marker to detect going back to persistence mode
* Review feedback
* Unused imports
2020-05-13 10:38:11 +01:00
Johan Andrén
dc678a6319
Docs: TestKit leaking into Java getting started guide ( #28793 )
2020-03-27 10:09:48 +01:00
Ignasi Marimon-Clos
f683241c40
Docs: examples for io streams with StreamConverters ( #28746 )
2020-03-27 09:56:59 +01:00
yiksanchan
a04a14d022
Update remoting.md ( #28811 )
2020-03-27 09:37:44 +01:00
Patrik Nordwall
37d87811b5
Doc example of Streams watch operator, #25468 ( #28752 )
2020-03-26 18:00:58 +01:00
Ignasi Marimon-Clos
04396d9c30
Cross-references to/from ref-docs vs operator docs ( #28788 )
2020-03-24 14:47:03 +01:00
Christopher Batey
59bad03cca
Remove FIXME and link to docs for typed pub sub ( #28767 )
2020-03-23 15:17:59 +01:00
B YI
1545f3fb25
Doc example for Sink.head ( #28782 )
2020-03-23 14:03:09 +01:00
Kirill Yankov
41f20cbb81
Persistence testkit implementation #15571 ( #26825 )
2020-03-20 14:18:43 +01:00
Ignasi Marimon-Clos
bcfdb896b0
Test jackson support for scala enumerations ( #28726 )
...
* Extends Spec over scala enumerations
* Adds documentation for scala enumeration support serializing with Jackson
2020-03-19 11:09:05 +01:00
Ignasi Marimon-Clos
3d8b4360f0
Docs: Example on the as/fromJavaStream operators ( #28745 )
2020-03-18 15:54:21 +01:00
Patrik Nordwall
94d5b04d93
Doc example of Sink.ignore, #25468 ( #28753 )
2020-03-18 12:42:20 +01:00
Renato Cavalcanti
990ad57527
Merge pull request #28727 from YikSanChan/patch-5
...
add missing full stop
2020-03-16 21:46:08 +01:00
Ignasi Marimon-Clos
69ce819b76
Fix link text
2020-03-13 22:36:51 +01:00
Johan Andrén
6f23b1fb4b
Update Source.actorRef sample to not use deprecated method #28679
2020-03-12 17:24:31 +01:00
yiksanchan
f01c9a3aa0
add missing full stop
2020-03-12 09:02:14 -07:00
Patrik Nordwall
1d16e847b5
Reliable delivery in Typed, #20984
...
Different approach than in classic AtLeastOnceDelivery because I would like:
* support flow control, with a work pulling approach
* be possible to use with or without persistence (without it may loose
messages if producer node crashes)
* detect lost messages on the consumer side and let that drive resends,
instead of aggressively resending from producer side
* deliver messages in order and deduplicate resent messages
* have an efficient protocol for acknowledgments over the network (not ack each message),
but still have a simple one-by-one protocol for the end user
* support 3 use cases (building blocks)
* point-to-point
* work pulling
* sharding
* optional durable queue, with one event sourced implementation
* protobuf serialization
* ApiMayChange
* reference docs and examples
* api docs
* doc example code missing so far
2020-03-12 15:37:16 +01:00
Renato Cavalcanti
6e171815b6
Adds ActorRef.ignore ( #28630 )
2020-03-12 12:40:56 +01:00
Arnout Engelen
dba69dba1d
Add docs and examples for RS fromPublisher #25468
2020-03-11 15:56:59 +01:00
Enno
45636e5af4
Docs: use https links ( #28713 )
2020-03-11 15:56:22 +01:00
Patrik Nordwall
1c58996276
doc: add link to video in CQRS page ( #28714 )
2020-03-11 15:55:56 +01:00
Johan Andrén
6bc4e3b94c
Sharded Daemon Process #28710
...
A new cluster tool for running a number of actor instances balanced over the cluster.
2020-03-10 18:04:09 +01:00
Johan Andrén
59ce257209
Distributed pubsub for typed ( #28625 )
...
* First stab at distributed pubsub for typed
* Also allow sending to a single subscriber across the topic
* Revert "Also allow sending to a single subscriber across the topic"
This reverts commit 4fd4f0b75c0dda01706dcde70645dcfa09da889b.
* Serializer and basic multi-jvm test
* docs
* Review feedback
* This reads better
* One brace too many
* sample formatting/headers/yadi
* Hide actual messages to ease bincomp evolution
* More tesssssts
* And even moar tessssssssts
* Review feedback addressed
* Same serialization as typed sharding
Mention turnaround in docs
2020-03-10 14:01:19 +00:00
Johan Andrén
d8aed9e9d3
Operator examples for statefulMapConcat #25468
2020-03-10 10:36:07 +01:00
Enno
52c83dca34
Docs: Sink.foreach ( #28693 )
2020-03-10 09:37:34 +01:00
Christopher Batey
0f77212913
Fix takeWhile description ( #28703 )
2020-03-09 17:15:48 +01:00
Christopher Batey
5b485be715
Add CQRS page to docs ( #28705 )
...
To highlight the cqrs sample in the index and make it more clear you can
use akka persistence for CQRS.
2020-03-09 14:20:23 +01:00
Johan Andrén
c46861ed26
Add LogWithMarker to Akka Stream #28450
2020-03-05 15:05:05 +01:00
Nicolas Deverge
72d2b7f034
Issue with the documentation for Partition ( #28682 )
...
The sample does not work as the outlet for odd numbers should be connected to the other port.
2020-03-04 17:12:23 +01:00
Christopher Batey
bfebb235d5
Doc onFailureWithBackoff ( #28356 )
2020-03-03 10:18:34 +01:00
Johan Andrén
1dc715ddc8
Add some nesting samples and clarifications to the docs #28659
2020-03-03 09:13:06 +01:00
Ignasi Marimon-Clos
8ba9fda183
Adds example to Source.completionStageSource ( #28639 )
2020-02-27 17:59:01 +01:00
Helena Edelson
26c333b52c
Productionize CurrentShardRegionState #27406 ( #28645 )
2020-02-26 10:32:28 -08:00
Ignasi Marimon-Clos
b5ddc2f224
Adds gzip and deflate to the operator list ( #28644 )
2020-02-26 13:50:43 +01:00
Enno
cff15cf40d
Docs: Source.repeat (and friends) ( #28615 )
2020-02-19 09:03:59 +01:00
Oliver Wickham
d946abd8d7
Fix incorrect link in 2.6 migration guide ( #28622 )
2020-02-18 15:13:06 +01:00
Razvan Vacaru
bb895619b9
Docs: sink seq operator examples ( #28616 )
2020-02-17 10:26:53 +01:00
Razvan Vacaru
56c13dcde5
Docs: add code examples for drop and dropWhile Operators ( #28613 )
2020-02-14 17:21:39 +01:00
Arnout Engelen
c032ac2fdb
Recommend config checker when migrating to 2.6 ( #28607 )
2020-02-13 15:11:48 +01:00
Patrik Nordwall
ece9e7d92b
Merge pull request #28595 from akka/wip-doc-chg-transport-patriknw
...
note about rolling update when changing transport
2020-02-12 16:53:30 +01:00
Patrik Nordwall
9b5f84286b
Remove not needed ReplicatedDataSerializer
2020-02-12 16:28:48 +01:00
Patrik Nordwall
b3539de125
note about rolling update when changing transport
2020-02-12 16:20:45 +01:00
Renato Cavalcanti
946ff235b7
Merge pull request #28593 from johanandren/wip-28437-hostname-verification-warning
...
Host name verification off is not necessarily bad
2020-02-12 15:55:01 +01:00
yiksanchan
4fb21c380d
Remove not needed ReplicatedDataSerializer
2020-02-11 17:05:51 -08:00
Evgeny Sidorov
dcdaa5a0dd
Example for Source.fromIterator #25468 ( #28582 )
...
* add example for Source.fromIterator #25468
* scala fmt code style fix
* don't use test as a sample for docs
2020-02-11 14:58:00 +01:00
