raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11
25664 commits 1 branch 31 tags 268 MiB
Commit graph

1642 commits

Author SHA1 Message Date
Łukasz Drygała
1290befec8
Update actor-lifecycle.md (#29391) 2020-07-16 13:41:18 +02:00
Joel Wee
54efafd07d Add mergePreferred, mergePrioritized docs (#25468) 2020-07-14 18:03:18 +08:00
davidlzs
9739e6f44d
Replace reference to deprecated API (#29381) 
Updated stream-composition.md to use Flow.fromSinkAndSourceCoupledMat or Flow.fromSinkAndSourceCoupled rather than the deprecated CoupledTerminationFlow.fromSinkAndSource.
 2020-07-14 08:48:33 +02:00
Ignasi Marimon-Clos
68fa87c58c
Merge pull request #29356 from ignasi35/monitor-operator-sample-code 2020-07-13 19:33:36 +02:00
Ignasi Marimon-Clos
6ca92cc543 javafmt 2020-07-13 14:04:28 +02:00
Ignasi Marimon-Clos
6c12ae117a PR comments 2020-07-13 10:46:16 +02:00
James Roper
558160702b
Added MergeSequence graph stage (#29247) 
Fixes #28769

Use case for this is if you have a sequence of elements that has been
partitioned across multiple streams, and you want to merge them back
together in order. It will typically be used in combination with
`zipWithIndex` to define the index for the sequence, followed by a
`Partition`, followed by the processing of different substreams with
different flows (each flow emitting exactly one output for each input),
and then merging with this stage, using the index from `zipWithIndex`.

A more concrete use case is if you're consuming messages from a message
broker, and you have a flow that you wish to apply to some messages, but
not others, you can partition the message stream according to which
should be processed by the flow and which should bypass it, and then
bring the elements back together acknowledgement. If an ordinary merge
was used rather than this, the messages that bypass the processing flow
would likely overtake the messages going through the processing flow,
and the result would be out of order offset acknowledgement which would
lead to dropping messages on failure.

I've included a minimal version of the above example in the documentation.
 2020-07-09 11:52:46 -04:00
Johan Andrén
996f424835
Ok/error protocol and failable ask #29186 (#29190) 
New type StatusReply simplifies the very common use case of replying to a request with either a successful reply or an error reply which can be repetitive to define for every actor, with the additional overhead of having to make sure each such sealed top type + 2 concrete reply classes has working serialization.
 2020-07-09 16:57:53 +02:00
Sebastian Alfers
ec08c9dde4
Fix SBR lease-implementation config example (#29361) 2020-07-09 09:48:28 +02:00
Ignasi Marimon-Clos
f187abddd1 Prefer monitoring from a separate stream (without blocking calls) 2020-07-07 17:08:11 +02:00
Ignasi Marimon-Clos
2b71abe78e Show less code. More informative comments (still hides blocking calls 2020-07-07 15:27:25 +02:00
Ignasi Marimon-Clos
024710a6e0 Headers and formats 2020-07-07 14:58:56 +02:00
Ignasi Marimon-Clos
0e3b4605ad Simplify code: instanceof, hide sleeps,... 2020-07-07 14:25:27 +02:00
franciscolopezsancho
65a0ec4683
Clarify that receptionist supports clustering (#29352) 2020-07-07 13:31:42 +02:00
Ignasi Marimon-Clos
95a000a51b Adds sample code for the monitor operator 2020-07-07 13:09:54 +02:00
Patrik Nordwall
5f70286b18
Merge pull request #29333 from akka/wip-mix-log-patriknw 
update the log message in docs for mixed versions
 2020-07-02 20:44:16 +02:00
Enno
7d328c9984
Docs: re-add akka.patterns page (#29024) 
* Docs: re-add akka.patterns page
* Add overloads with ClassicActorSystemProvider
* docs for Java `after`
 2020-07-02 10:19:11 +02:00
Enno
101c1d9b65
Docs: Actor sink stream operators (#29171) 2020-07-01 21:27:29 +02:00
Patrik Nordwall
1e5cb5a720
Merge pull request #29310 from ennru/symbolic-akka-version 
docs: show Akka version as symbol
 2020-07-01 17:15:52 +02:00
Patrik Nordwall
158faa24e3 update the log message in docs for mixed versions 2020-07-01 11:30:16 +02:00
jeremie-seguin
6130b33e08
Fix doc typo (#29326) 2020-06-30 10:52:26 +02:00
Enno
4947c07385
Docs: link to object API docs (#29195) 2020-06-26 09:07:01 +02:00
Enno Runne
1347b713f6 docs: show Akka version as symbol 2020-06-25 11:59:37 +02:00
Arnout Engelen
b95c82e63b
Docs: Document reference.conf appending on gradle+kotlin (#29274) 2020-06-25 10:11:23 +02:00
Christopher Batey
7dfcc0bfd0
Validate leveldb write plugin is enabled for leveldb read plugin (#29288) 
* Validate leveldb write plugin is enabled for leveldb read plugin

And remove some weird overriding

* mima
 2020-06-24 08:01:03 +01:00
Renato Cavalcanti
66d9dc33f6
Merge pull request #28986 from manishbansal8843/patch-1 
Improved utilities/logging documentation
 2020-06-19 13:31:05 +02:00
Johan Andrén
1e9e984727
Removing, deprecating and replacing usage of black/whitelist (#29254) 2020-06-18 15:48:28 +02:00
Johan Andrén
25ea7b7f5e
Remove or replace master/slave terminology from tests and API docs (#29252) 
* Remove or replace master/slave terminology from tests and API docs
* Replace master where it would potentially imply being master/slave
 2020-06-18 08:17:46 +02:00
Johan Andrén
4811b53917
Merge pull request #29219 from akka/feature-remember-entities-rework 
Rework of Remember Entities and sharding internals #27763
 2020-06-17 09:07:49 +02:00
Enno
bc68f0d650
Docs: Actor source stream operators (#29178) 2020-06-15 14:11:28 +02:00
Johan Andrén
c5aa918732 Language fix and don't showcase leveldb 2020-06-11 16:07:50 +02:00
Johan Andrén
25a1daa0d2 Majority plus in docs 2020-06-11 16:05:36 +02:00
Ignasi Marimon-Clos
4faf806266
Merge pull request #29203 from ignasi35/example-for-throttle-op 2020-06-10 17:29:40 +02:00
Patrik Nordwall
b29de18e04
doc: add link to SBR video (#29211) 
* and another link to Stateful or Stateless
 2020-06-10 10:04:37 +02:00
Ignasi Marimon-Clos
0c88b4ba10
Adds skeleton pages for gunzip and inflate. (#29214) 2020-06-10 09:51:11 +02:00
Enno
7e69b990b9
Docs: Discovery via DNS (#29153) 2020-06-09 17:33:52 +02:00
Ignasi Marimon-Clos
411a11dd9d No commit without a formatting follwup 2020-06-09 15:55:43 +02:00
Ignasi Marimon-Clos
6eb1a9e1ef Split example to ease into the details. PR Comments 2020-06-09 15:53:04 +02:00
Ignasi Marimon-Clos
506cbc5bf4 x-ref to queue.md 2020-06-09 09:41:11 +02:00
Ignasi Marimon-Clos
a72ee4d5b8 Adds throttle example 2020-06-08 20:06:32 +02:00
Patrik Nordwall
9f05948f29
Link to new Kubernetes deployment guide (#29187) 2020-06-05 11:35:24 +01:00
Ryan Braley
7bae3d8160
Docs: Fix a small typo in sharded daemon process docs (#29097) 2020-06-05 11:36:36 +02:00
Arnout Engelen
afc9813c55
Docs: WithContext (#29088) 2020-06-05 11:31:10 +02:00
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
Arnout Engelen
d73ae8ddb2
Remove mention of materializer from streams quickstart (#29169) 2020-06-04 09:19:01 +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
Xavier GUIHOT
33d64f9dba
Small fix in Buffer's doc (#29157) 2020-06-02 17:41:26 +02:00
Christopher Batey
09aa9ffc24 Link to akka cluster video 2020-06-02 07:18:02 +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