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

25467 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johan Andrén
513d6f5d06 More reasonable DNS timeout avoiding resolution fail in test #29858 2020-12-07 13:54:20 +01:00
Josep Prat
2c659a046e
Refactor example to make it easier to copy-paste #29578 (#29860) 
* Refactor example to make it clear #29578

Restructure example

* Fix formatting

* Right formatting to disable format checker
 2020-12-07 09:47:18 +01:00
Enno Runne
c931b9bb93
docs: Link project info to snapshots (#29862) 2020-12-07 09:00:52 +01:00
Josep Prat
12513ec7df
Normalize Event Sourcing wording #29577 (#29856) 2020-12-07 08:41:43 +01:00
Robert Walker
8b71fac817
Fixed a formatting issue, the '@scala[]' marker, does not seem to handle CRLF (#29857) 2020-12-04 10:27:48 +01:00
Patrik Nordwall
021e7d58bc
Don't cache temp actors in ActorRefResolveCache, #29828 (#29834) 
* problem described in in issue
* temp (ask) ActorRef shouldn't be cached
* similar to to the ActorRef compression that was fixed
  in https://github.com/akka/akka/pull/28823
* temp ActorRef doesn't contain the ActorRef uid so it can
  be resolved to an ActorRef with an old cached Association
* additionally, invalidate the cached Association if it has
  been removed after quarantine
* test that reproduces the problem in the issue
* also verified with the Main example in the issue
 2020-12-04 08:14:58 +01:00
Christopher Batey
3602ffa4d9
Ignore gossip desrialization failures (#29848) 
* Ignore gossip desrialization failures

Only to happen suring a rolling upgrade. Gives us the option to do
incompatible things in Gossip and have the old nodes ignore the
deserialization error.

* Review feedback
 2020-12-02 18:50:16 +00:00
Enno Runne
ffb21da246
Stream Testkit: new-API-friendly (#29831) 2020-12-01 12:06:09 +01:00
Patrik Nordwall
5db6a3a491
links to platform guide (#29846) 2020-11-30 20:00:39 +01:00
Ignasi Marimon-Clos
12ca84c247
Produce a BOM for Akka libraries (#29839) 2020-11-30 16:39:14 +01:00
Johan Andrén
78ffa91c4a
Fix for stream ref test fail #29843 (#29845) 2020-11-30 11:42:03 +01:00
Nitika Agarwal
e290130386
Add examples for asInputStream and asOutputStream (#29830) 2020-11-30 10:39:14 +01:00
Christopher Batey
385e075fdc
Fix port configuration for basic cluster example spec (#29836) 2020-11-30 09:32:20 +01:00
Jesse
ae22f114b2
Update persistence.md (#29844) 
Fix typo, although I'm in support of adding 'commandler' to the dictionary.
 2020-11-30 09:30:21 +01:00
Renato Cavalcanti
485e21c9a8
fixed typo: wort -> worth [ci skip] (#29840) 2020-11-25 16:44:19 +01:00
Enno Runne
459e74b921
Operator docs: examples for asSource/FlowWithContext (#29822) 
* Operator docs: examples for asSource/FlowWithContext

* javafmtAll

* Try to capture the essence better

* Update index

* Include the test use in the snippets
 2020-11-25 12:21:16 +01:00
Johan Andrén
c9980216a1
Automatic closing of graph stage sub inlets/outlets #29790 2020-11-23 15:12:39 +01:00
Renato Cavalcanti
510e7374d5
fix logging: expectTerminated instead (#29827) 2020-11-19 11:45:32 +01:00
Enno Runne
fb886638fd
Revert "Stream Testkit: new-API-friendly" (#29826) 
This reverts commit d64bb0aba5.
 2020-11-18 15:42:12 +01:00
Enno Runne
5c1108eeab
Move to travis-ci.com (#29824) 2020-11-17 15:49:06 +01:00
Patrik Nordwall
0be3712694
move identify to /MultiNodeTypedClusterSpec (#29821) 
* just a small cleanup
 2020-11-16 13:34:18 +01:00
Christopher Batey
02fc67f6a1
Fix deprecated versin is cluster sharding settings (#29819) 2020-11-16 12:40:26 +01:00
Scala Steward
5c4e779bce
Update sbt-scalafix to 0.9.23 (#29804) 2020-11-16 12:39:46 +01:00
Scala Steward
90146f39ec
Update metrics-core, metrics-jvm to 4.1.14 (#29807) 2020-11-16 12:32:01 +01:00
Scala Steward
f75ffde652
Update scalacheck to 1.15.1 (#29809) 2020-11-16 12:31:05 +01:00
Scala Steward
03e0b99b06
Update sort-imports to 0.5.5 (#29805) 2020-11-16 12:08:24 +01:00
Patrik Nordwall
4fa733c146
Include entries DData Gossip message dynamically based on size, #28421 (#29751) 2020-11-16 12:00:16 +01:00
Scala Steward
ac58f7d4ca
Update aeron-client, aeron-driver to 1.31.1 (#29806) 
* Update aeron-client, aeron-driver to 1.31.1

* Update agrona to 1.8.0

Co-authored-by: Christopher Batey <christopher.batey@gmail.com>
 2020-11-16 10:52:30 +01:00
Patrik Nordwall
55239e5da9
Merge pull request #29814 from ennru/ennru-assertAllStagesStopped-javadsl 
Stream Testkit: use assertAllStagesStopped with system in the Java DSL
 2020-11-16 10:50:32 +01:00
Horváth Martin
1e8ca217bb
Fix passing of lease settings in typed cluster sharding. (#29671) 
* Fix passing of lease settings in typed cluster sharding. (#29662)

* Fix binary compatibility. (#29662)

* Fix deprecation version. (#29662)
 2020-11-16 09:36:17 +00:00
Enno Runne
d64bb0aba5
Stream Testkit: new-API-friendly (#29815) 2020-11-16 09:59:41 +01:00
Enno Runne
d253c6402d
Docs: use RestartSettings (#29788) 2020-11-16 08:24:56 +00:00
Christopher Batey
3328d60244
Merge pull request #29817 from YikSanChan/tiny-api-improvement 
not isEmpty => nonEmpty
 2020-11-16 08:03:31 +00:00
Yik San Chan
e4d8843971 not isEmpty => nonEmpty 2020-11-14 22:58:00 -08:00
Enno Runne
32e8907ae0 Stream Testkit: use assertAllStagesStopped with system in the Java DSL 2020-11-13 13:21:38 +01:00
Ignasi Marimon-Clos
24d01a101a
Configure visibility (#29797) 2020-11-10 09:41:44 +01:00
Sebastian Alfers
0d6282cffe
Reset index if it gets out of sync with the snapshot storage (#29769) 
* use Queue for SnapshotTestKit to avoid getting index out of sync with the snapshot storage
* immutable collections via synchronized
 2020-11-09 17:44:23 +01:00
Johannes Rudolph
49714b0374
Merge pull request #29802 from jrudolph/29800-fix 
tests: shorten probabilitic test in BoundedSourceQueueSpec
 2020-11-09 16:05:40 +01:00
Johannes Rudolph
c48ca096d2
tests: shorten probabilitic test in BoundedSourceQueueSpec 
Fixes #29800
 2020-11-09 15:17:16 +01:00
Patrik Nordwall
12110822df
Merge pull request #29789 from johanandren/wip-29787-leveldb-recovery-slow 
Increase timeout to make room for leveldb disk access slow
 2020-11-09 12:24:28 +01:00
Patrik Nordwall
48f88772f1
cleanup associations when handshake didn't complete, #29615 (#29763) 
* symptom was continously logged "Quarantine of [] ignored because unknown UID",
  triggered from the Association.setupIdleTimer task
* when handshake wasn't completed for some reason the UID is unknown and then
  this task continues forever
* abort such associations and cancel the idle task in that case
* also cleanup such associations from AssociationRegistry.removeUnusedQuarantined
* 3 state ADT for the uniqueAddress
 2020-11-09 11:50:45 +01:00
Enno Runne
a57742f31b
Docs: link to videos (#29799) 2020-11-09 11:36:39 +01:00
Christopher Batey
abfd699985
Harden lease majority spec (#29793) 
The failure was due to timing out waiting for the downed side to
terminate. These changes half the time it takes for this to happen.
 2020-11-09 10:48:37 +01:00
yiksanchan
61743a80eb
Add type annotation for public method (#29798) 2020-11-09 09:27:05 +01:00
eyal farago
1aaa2fb6bf
Akka 29784 stateful map concat relax f ret type (#29792) 
* akka-29730__register_newshells_when_no_active_interpreters: unrelated warnings that act as compilation errors on my env.

* akka-29730__register_newshells_when_no_active_interpreters: introduce a reproduction for akka-29730. actor interpreter failed to register new shells introduced by flatMapPrefix when the current interpreter has completed.

* akka-29730__register_newshells_when_no_active_interpreters: fix akka-29730

* akka-29730__register_newshells_when_no_active_interpreters: scalafmtAll

* Update akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala

* akka-29730__register_newshells_when_no_active_interpreters: style

* akka-29730__register_newshells_when_no_active_interpreters: fmt

* akka-29730__register_newshells_when_no_active_interpreters: scalafmt

* akka-29730__register_newshells_when_no_active_interpreters: simplify shortCircuitBatch's condition.

* akka-29730__register_newshells_when_no_active_interpreters: salfmt

* akka-29730__register_newshells_when_no_active_interpreters: println => log.debug

* Update akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala

Co-authored-by: eyal farago <eyal.farago@gmail.com>

* Update akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala

* akka-29730__register_newshells_when_no_active_interpreters: tailrec shortCircuitBatch

* akka-29784__statefulMapConcat_relax_f_ret_type: modify scala dsl's statefulMapConcat and mapConcat to take a function returning an IterableOnce.

* akka-29784__statefulMapConcat_relax_f_ret_type: scalafmtall

* akka-29784__statefulMapConcat_relax_f_ret_type: remove redundant import.

* akka-29784__statefulMapConcat_relax_f_ret_type: remove another unused import.

* akka-29784__statefulMapConcat_relax_f_ret_type: organize imports and annotations around ccompat

* akka-29784__statefulMapConcat_relax_f_ret_type: scalafmtall

* akka-29784__statefulMapConcat_relax_f_ret_type: filter false negative MIMA issues.

* akka-29784__statefulMapConcat_relax_f_ret_type: flowWithCtx

* akka-29784__statefulMapConcat_relax_f_ret_type: avoid deprecated methods in scala 2.13

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
 2020-11-09 09:19:23 +01:00
Ignasi Marimon-Clos
bcee56f4b9
Review writeup for RES direct deplication in docs (#29796) 2020-11-06 16:09:42 +01:00
Johan Andrén
2b8d0b2285
BoundedSourceQueue API #29574 
A new queue implementation that drops new elements immediately when the buffer is full. Does not use async callbacks like Source.queue with OverflowStrategy.dropNew, which can still result in OOM errors (#25798).
 2020-11-06 09:00:15 +01:00
Sean Glover
779161d556 BoundedQueueSource API 2020-11-05 14:05:49 -05:00
Domantas Petrauskas
b34f9eb445
save snapshot after replaying events if retention criteria indicates missing snapshot #29631 2020-11-04 09:32:17 +01:00
Renato Cavalcanti
028ad29164
Fix cluster sharding with remember entities test (#29773) 
* fix cluster sharding with remember entities test

* send BeginHandOff to all regions
 2020-11-02 17:09:56 +01:00