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

25292 commits

This branch
This branch
All branches
Author SHA1 Message Date
Christopher Batey
73f04f0a23
Update latest patch version (#29580) 2020-09-10 09:59:57 +02:00
Patrik Nordwall
7e768fa732
Merge pull request #29551 from akka/wip-29543-alloc-after-rebalance-patriknw 
Allocate rebalanced shards immediately, #29543
 2020-09-09 18:45:46 +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
Aleh Reishal
e0ceb71ccd
Fix calculating backoff delay in order to prevent IllegalArgumentExce… (#29569) 
* Fix calculating backoff delay in order to prevent IllegalArgumentException #29568

* Fix calculating backoff delay in order to prevent IllegalArgumentException #29568 / remove BackoffCalculatorSpec due to it is difficult to make calculateDelay testable and not tp break binary backward compatibility
 2020-09-08 12:38:32 +02:00
Arnout Engelen
6e71accd90
Publish releases as 'github release' as well (#29572) 
To make it show up nicely in the right-side sidebar
 2020-09-08 11:48:06 +02:00
Christopher Batey
6c631a65fe
Reduce sharding warnings when there are no buffered messages (#29525) 
* Reduce sharding warnings when there are no buffered messages

If shard regions are started before the cluster is formed warnings are
logged. The user can wait until SelfUp but for the cases they don't make
logging debug until the user has buffered messages.

* Review feedback

* Review feedback
 2020-09-08 09:17:34 +01: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
Johannes Rudolph
540c7205e1
testkit: do not try to use 127.x.y.255 as a test localhost address (#29566) 
For some arcane reason, the JDK seems to block binding attempts to that
address.
 2020-09-07 19:29:36 +02:00
Patrik Nordwall
6becd8e0ee
Merge pull request #29539 from akka/wip-27786-setDeliverySnapshot-patriknw 
Fix time in AtLeastOnce.setDeliverySnapshot, #27786
 2020-09-07 15:15:47 +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
d5bb125ae0
Merge pull request #29495 from akka/feature-active-active-event-sourcing 
Replicated event sourcing
 2020-09-04 10:35:21 +02:00
Patrik Nordwall
b09653c977 Allocate rebalanced shards immediately, #29543 
* Otherwise it will continue to deallocate when there is no traffic
  that triggers allocations
 2020-09-04 10:27:29 +02:00
Patrik Nordwall
bb985b82c6 fix compilation errors 2020-09-03 13:42:42 +02:00
Patrik Nordwall
4629cd44e4 Merge branch 'master' into feature-active-active-event-sourcing 2020-09-03 11:52:41 +02:00
mgutmanis
33fda3ae6f
Improve Shard#entityCreated API performance #29520 
Expose size of reachable actor count
 2020-09-02 16:49:36 +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
Johan Andrén
192be028a0
Sharding request-to-start but already started logging (#29545) 2020-09-02 14:18:44 +02:00
Patrik Nordwall
9b709df2d0
Fix acceptable-heartbeat-pause in cluster.StressSpec, #29512 (#29541) 2020-09-02 12:48:52 +02:00
Patrik Nordwall
cd8d5c5d08 Fix time in AtLeastOnce.setDeliverySnapshot, #27786 
* to be consistent with internalDeliver when recoveryRunning
 2020-09-01 12:08:05 +02:00
yiksanchan
4249b02c40
Fix grammar in exception message (#29533) 2020-09-01 10:57:15 +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
Christopher Batey
7368e13458
Start ShardedDaemon pinging once member is up (#29526) 2020-08-28 15:37:04 +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
Patrik Nordwall
57fb9e9093
Merge pull request #29517 from scala-steward/update/sbt-java-formatter-0.6.0 
Update sbt-java-formatter to 0.6.0
 2020-08-24 14:22:30 +02:00
Scala Steward
1ee9a322b6
Update sbt-reproducible-builds to 0.25 (#29305) 2020-08-24 13:20:24 +02:00
Christopher Batey
d1114495dd
Feedback from creating replicated entity sample (#29510) 
* Fix javadsl and remove shard regions from ReplicatedSharding

* Simplyfy sharding API for replicated event sourcing

As the ShardRegion access has been removed then we will only initially
support Entity's with ShardingEnvelope meaning we can remove the type
param.

Also provide convenience constructors for running a replica on a role
and a replica in each DC

* Compile

* Review feedback

* feedback
 2020-08-24 10:52:28 +01:00
Enno
d9c610eceb
docs: render depenency on Futures page correctly (#29513) 2020-08-24 11:45:27 +02:00
Scala Steward
cfbbf74b77
Update jctools-core to 3.0.1 (#29519) 2020-08-24 11:29:31 +02:00
Christopher Batey
165990ba01
Pin jackson to 2.10. (#29521) 2020-08-24 11:28:47 +02:00
Scala Steward
988e240368
Update metrics-core, metrics-jvm to 4.1.12.1 (#29518) 2020-08-24 10:06:17 +02:00
Scala Steward
b90ed1c263
Update silencer-lib, silencer-plugin to 1.7.1 (#29516) 2020-08-24 08:44:03 +01:00
Scala Steward
8f5c200e1e
Update sbt-java-formatter to 0.6.0 2020-08-24 02:03:30 +02:00
Patrik Nordwall
dd128b3e8f
Merge pull request #29506 from akka/wip-29505-MultiDcJoin2Spec-patriknw 
increase timeout in MultiDcJoin2Spec, #29505
 2020-08-21 12:14:43 +02:00
Patrik Nordwall
ff9b8f44ea increase timeout in MultiDcJoin2Spec, #29505 2020-08-19 09:30:13 +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
Patrik Nordwall
e50b32ec9a
Merge pull request #29371 from raboof/protobuf-v3-reproducible 
Make akka-protobuf-v3_2.12-2.6.x reproducible again
 2020-08-18 12:57:14 +02:00
Patrik Nordwall
0601b7e83c
Merge pull request #29471 from akka/wip-29344-write-timeout-patriknw 
fix write consistency timeout in Sharding, #29344
 2020-08-18 12:23:49 +02:00
Patrik Nordwall
ae83968286
Merge pull request #29474 from akka/wip-29423-ClusterSingletonManagerLeaseSpec-patriknw 
harden ClusterSingletonManagerLeaseSpec, #29423
 2020-08-18 12:23:07 +02:00
Patrik Nordwall
2be7e4d6c4
Merge pull request #29473 from akka/wip-29467-BackoffSupervisorSpec-patriknw 
Harden BackoffSupervisorSpec, #29467
 2020-08-18 12:20:51 +02:00
Patrik Nordwall
34dfca53c8
Merge pull request #29496 from akka/wip-29185-RandomizedSplitBrainResolverIntegrationSpec-patriknw 
reduce combinations in RandomizedBrainResolverIntegrationSpec, #29185
 2020-08-18 12:20:01 +02:00
Patrik Nordwall
0f2e2953fc
Merge pull request #29498 from akka/wip-29490-role-patriknw 
convenience for ShardedDaemonProcess role, #29490
 2020-08-18 12:18:23 +02:00
Patrik Nordwall
6a7a7e093f
Merge pull request #29500 from chbatey/issue-29480 
Fix patch versin for scala when overriding
 2020-08-18 12:16:58 +02:00
Patrik Nordwall
da404071dc
full convergence also for joining nodes for first multi-dc join, #29486 (#29499) 2020-08-18 11:49:19 +02:00
Christopher Batey
c934511c42
Forward terminated from ShardCoordinator to RebalanceWorker (#29463) 
* Forward terminated from ShardCoordinator to RebalanceWorker

Avoiding the need for rebalance workers to watch shard regions which is
expensive as there is one rebalance worker per shard

* Review feedback
 2020-08-18 11:25:01 +02:00