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

25448 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
Johannes Rudolph
708f8b870c stream: a fast dropping queue implementation 2020-11-02 09:14:01 -05:00
Patrik Nordwall
762dfb5e8b
Merge pull request #29348 from raboof/artery-shutdown-observability 
More debug logging for Artery transport shutdown
 2020-11-02 15:02:53 +01:00
Johan Andrén
6685f0d6ed Increase timeout to make room for leveldb disk access being really slow on Jenkins #29787 2020-11-02 13:23:48 +01:00
Patrik Nordwall
a19e09c1e9
Merge pull request #29783 from aumann/behavior-testkit-signal-actorthread 
Fix BehaviorTestKit.signal false alarm in thread check  #29779
 2020-11-02 11:38:04 +01:00
Josep Prat
629759b72b
Add limitation about supervision in sync Testkit #29767 (#29778) 
Refs: #29767
Currently, sync Testkit doesn't support supervision as it often involves async interactions.
 2020-11-02 09:23:50 +01:00
Patrik Nordwall
6c197346c9
Merge pull request #29774 from akka/jrudolph-patch-1 
cleanup test comment
 2020-11-02 08:51:37 +01:00
Alexander Aumann
3ba5e89433 Fix BehaviorTestKit.signal false alarm in thread check #29779 2020-11-01 00:07:21 +01:00
Scala Steward
dab8f3b642
Update metrics-core, metrics-jvm to 4.1.13 (#29725) 2020-10-28 09:52:29 +01:00
Patrik Nordwall
8d25ca2012
simplify the stopping example, #28144 (#29760) 
* need for the callback variant should be a rare so we should not
  confuse the users with it in this example
* mention of callback in api docs should be enough
 2020-10-27 17:27:43 +01:00
Renato Cavalcanti
592b1d10ad
Isolate shard init logic to own method (#29759) 2020-10-27 17:23:36 +01:00
Scala Steward
2ecfdb9c49
Update sbt-scalafmt to 2.4.2 (#29701) 2020-10-27 16:59:50 +01:00
Arnout Engelen
4440184c0b
Update mima to 0.8.1 (#29764) 
Look, ma: no ivy!
 2020-10-27 16:53:23 +01:00
Johannes Rudolph
f6d137276d
cleanup test comment 2020-10-27 13:13:34 +01:00
eyal farago
2bf09d8da2
stream: register newshells with no active interpreters (#29731) 
Fixes #29730
 2020-10-27 13:11:23 +01:00
Patrik Nordwall
91a5d4b093
Merge pull request #29761 from chbatey/issue-29689 
DEBUG logging for BasicClusterManualSpec
 2020-10-26 14:09:35 +01:00
Peter Vlugter
1581696f59
Fix typo in docs for cluster sharding rolling updates (#29771) 2020-10-22 12:37:01 +02:00
Josep Prat
a023821f8e
Fixes the wording of the Scaladoc on the unwatched method (#29766) 2020-10-21 17:09:30 +02:00
Christopher Batey
ee74c541d1
Dont rely on DNS for a doc spec (#29762) 2020-10-21 10:15:36 +02:00
Muskan Gupta
b705ded314
Improving docs- removing redundant phrases (#29744) 
* Improving docs- removing redundant phrases

* Apply suggestions from code review

Co-authored-by: Arnout Engelen <github@bzzt.net>

* Making changes to improve docs

Co-authored-by: Arnout Engelen <github@bzzt.net>
 2020-10-21 09:27:31 +02:00