Commit graph

1608 commits

Author SHA1 Message Date
Stefano Baghino
190d2b6a62
shutdown it down -> shut it down (#29686) 2020-10-05 09:18:25 +02:00
r-glyde
a4acf23d05
Restart(Source|Flow|Sink): Configurable stream restart deadline (#29591) 2020-10-05 09:12:15 +02:00
Muskan Gupta
4cc3c58a08
Making docs better (#29623)
Co-authored-by: Arnout Engelen <github@bzzt.net>
2020-10-02 16:30:05 +02:00
Patrik Nordwall
90b79144e5
Documentation for Sharding rolling update (#29666) 2020-09-30 12:31:03 +02:00
Muskan Gupta
94d62f34c1
Add completion timeout example (#29673)
* Adding example for completionTimeout

* Adding header to file

* Modifying example

* Modifying duration

* Modifying syntax for duration
2020-09-29 15:47:36 +02:00
Renato Cavalcanti
294c534d15
Fix links to Microsoft CQRS and ES reference (#29596) 2020-09-29 08:35:53 +02:00
Christopher Batey
91398cdcdd
Cluster sharding health check (#29638)
* and update akka-docs/src/main/paradox/typed/cluster-sharding.md
2020-09-25 12:55:29 +02:00
Patrik Nordwall
d7441fd93c
Merge pull request #29595 from YikSanChan/patch-14
Fix grammar
2020-09-24 12:53:04 +02:00
Arnout Engelen
48a7306109
Fix documentation version warning for 'series' page (#29647) 2020-09-22 19:50:26 +02:00
Muskan Gupta
a12867b8b1
Docs: Reduce operator (#29641)
Co-authored-by: Arnout Engelen <github@bzzt.net>
2020-09-22 15:28:35 +02:00
Christopher Batey
306cf65863
Docs for which versions support RES (#29642) 2020-09-22 12:24:50 +02:00
Muskan Gupta
ac648a5940
Adding example of fold for sink #25468 2020-09-21 18:01:14 +02:00
Ignasi Marimon-Clos
ffc4235980
Adds mapAsync(Unordered) operator samples (#29600) 2020-09-16 12:24:49 +02:00
yiksanchan
c67251ff4d
Fix markdown link with brackets (#29594) 2020-09-14 16:26:34 +02:00
yiksanchan
10641df346
Fix grammar (#29593) 2020-09-14 16:25:33 +02:00
yiksanchan
2ecad79627
Fix grammar 2020-09-13 18:31:53 -07:00
Upapan Vongkiatkachorn
51e32412d8
Adding missing word to Split Brain Resolver documentation (#29582) 2020-09-11 13:32:47 +02:00
Patrik Nordwall
cd80a26859
Merge pull request #29583 from akka/wip-res-video-patriknw
Link to Replicated Event Sourcing video
2020-09-11 08:50:48 +02:00
Patrik Nordwall
f0b3c9089b
Holistic shard allocation strategy, #29543 (#29555)
* The rebalance in the LeastShardAllocationStrategy is only comparing the region
  with most shards with the one with least shards. Makes the rebalance rather
  slow. By default it's only rebalancing 1 shard at a time.
* This new strategy looks at all current allocations to find the optimal
  number of shards per region and tries to adjust towards that value.
  Picking from all regions with more shards than the optimal.
* Absolute and relative limit on how many shards that can be rebalanced
  in one round.
* It's also not starting a new rebalance round until the previous has
  completed.
* unit tests
* second phase for fine grained rebalance, due to rounding it will not be perfect in the first phase
* randomized unit test
* configuration settings
* docs
2020-09-11 08:49:45 +02:00
Patrik Nordwall
11673749e4 Link to Replicated Event Sourcing video 2020-09-10 15:17:14 +02:00
Ignasi Marimon-Clos
59e6bd8651
Fix markdown syntax for link that uses parens (#29576) 2020-09-09 17:21:25 +02:00
Arnout Engelen
ca59d8149c
Enable fatal errors for docs (#29570) 2020-09-08 15:10:21 +02:00
Patrik Nordwall
9074b434c2
minor doc updates for replicated event sourcing (#29561)
* also link to Projections in cqrs page
2020-09-08 08:29:28 +02:00
Josep Prat
9113c07da5
Add links to how to deal with blocking APIs #29544 (#29547)
Refs: #29544
Adds a couple of links to dealing with blocking APIs
2020-09-07 14:10:08 +01:00
Patrik Nordwall
a548949143
Chunked messages in reliable delivery, #24276 (#28915)
* To avoid head of line blocking from serialization and transfer of large messages
  this can be enabled.
* ProducerController setting to chunk messages
* split up large messages in chunks in ProducerController
  and assemble again in ConsumerController
* serialization moved to these actors instead of in the Artery stream
* other messages (for other actors) can interleave with the chunks
* serializer for ChunkedMessage in SequencedMessage and MessageSent
* cleanup partially stored chunked messages
* reference docs
* mima filters
* additional test for sending the Request after half window size
* enforce that chunk-large-messages=off for sharding and work-pulling
2020-09-07 14:02:52 +02:00
Patrik Nordwall
7bf12721c1 Merge branch 'master' into feature-active-active-event-sourcing 2020-09-02 15:46:06 +02:00
Renato Cavalcanti
32ec0428d3
Document workaround for jackson serialiaztion of scala case objects (#29531)
* workaround for jackson serialiaztion of scala case objects

* improved sentence
2020-09-02 14:19:13 +02:00
Patrick Altaie
99f21dba3a
Add "akka" prefix to TCK code sample (#29529)
The current code sample for trying out the TCK misses the "akka" prefix
which means that the TCK test will fail with an error regarding not
specifying a journal plugin (because the journal plugin property is
wrong in the sample)

Fixes #29528
2020-09-01 09:42:25 +02:00
Josep Prat
1180b8364e
Use the correct name for Akka HTTP (#29527)
Fixes the typo in the name of Akka HTTP, it's written in lower case but the project name is in upper case.
2020-08-26 12:03:01 +02:00
Ignasi Marimon-Clos
418d6d3ec0
Prefer "update" over "upgrade" when rolling (#29523) 2020-08-25 11:11:06 +02:00
Ignasi Marimon-Clos
728dda874e
Event migration improvements (#29514) 2020-08-25 11:10:33 +02:00
Christopher Batey
2d9660f847 Final review feedback 2020-08-25 10:02:27 +01:00
Enno
d9c610eceb
docs: render depenency on Futures page correctly (#29513) 2020-08-24 11:45:27 +02:00
Patrik Nordwall
efe02935cd
doc: rolling update from 2.5.x to 2.6.2 (#29501) 2020-08-18 15:16:44 +02:00
Christopher Batey
eae102acb1 Make ShardingDirectReplication private (#29492)
* Make ShardingDirectReplication private

And provider user API to provide ReplicaId so that local messages don't
need to be forwarded to sharding to just be dropped

* Update docs to say direct replication is on my default

* Doh
2020-08-17 07:54:34 +01:00
Christopher Batey
260276fd90 Turn on direct replication by default (#29493) 2020-08-17 07:54:34 +01:00
Christopher Batey
849018b81e Replicated Sharding improvements (#29483)
* WIP

* Finishing touches to sharding updates

* Review feedback
2020-08-17 07:54:34 +01:00
Patrik Nordwall
779e827495 Counter example, shopping cart 2020-08-17 07:54:34 +01:00
Patrik Nordwall
2e0821c2f0 ORSet example, MovieWatchList 2020-08-17 07:54:33 +01:00
Patrik Nordwall
d078a6b65f LwwTime example
* show event and command handlers of the blog example in docs
* add blog example for Java
2020-08-17 07:54:33 +01:00
Patrik Nordwall
ac469e1a56 Polish Auction example
* adjust the style in the Scala example
  * AuctionEntity class instead of Setup class that is passed around
* add timer in recovery completed
2020-08-17 07:54:33 +01:00
Patrik Nordwall
fb5f5dc145 a few more things when reviewing replicated event sourcing (#29461) 2020-08-17 07:54:33 +01:00
Christopher Batey
f41f093372 Rename replicated settings (#29460) 2020-08-17 07:54:33 +01:00
Christopher Batey
67eb74f076 Embed akka serialization inside jackson serialization (#29455)
* Embed akka serialization inside jackson serialization

Allows re-use of existing serializers when embedding the types in
Jackson

* Fix false dead code warning

* Move marker trait and add docs

* Remove module and document adding annotations

* Review feedback
2020-08-17 07:54:33 +01:00
Patrik Nordwall
7348939ff4 DRY ReplicatedEventSourcedBehavior.apply (#29454)
* and change signature of withEventPublishing and withDirectReplication
2020-08-17 07:54:33 +01:00
Patrik Nordwall
cd821fe3f8 Minor adjustments to replicated es docs (#29450)
* Minor adjustments to replicated es docs

* and a few aa leftovers

* link to more examples
2020-08-17 07:54:33 +01:00
Johan Andrén
9fb76bbea4 Tagging for replicated event sourcing (#29442)
* Tagging for replicated event sourcing
* Docs improvements
* Support for currentEventsByTag in persistence testkit and test coverage for tags in replicated
2020-08-17 07:54:33 +01:00
Christopher Batey
c945fbd7a1 Java auction example (#29443) 2020-08-17 07:37:59 +01:00
Johan Andrén
4b27bc34a8 Document hot standby for replicated event sourcing (#29439) 2020-08-17 07:37:59 +01:00
Johan Andrén
b03412d5b2 Rename active active to replicated event sourcing (#29435)
* Move active active internals into the internal package

* Renaming active active to Replicated Event Sourcing

* Rename of Active Active to Replicated Event Sourcing

* Revert changes to testkit

* Java test formatting...

* Gave up on getting apidoc to link to EventSourcedBehavior and made code snippets of it

Co-authored-by: Christopher Batey <christopher.batey@gmail.com>
2020-08-17 07:37:59 +01:00