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

22003 commits

This branch
This branch
All branches
Author SHA1 Message Date
Konrad Malawski
9e62f5b5d5 may want to benchmark typed persistence 2018-03-13 00:40:13 +09:00
Konrad Malawski
a537abc77d add MDC logging to StdOutLogger, making withMdc in Akka typed usable 2018-03-13 00:40:13 +09:00
Patrik Nordwall
e61f833dc3 make PersistingEvent MutableBehavior 
fix some tests, snapshots still not working
 2018-03-13 00:40:13 +09:00
Patrik Nordwall
44445140f5 EventsourcedRunning, internalPersist, internalPersistAll 
* I don't think the JournalInteractions should be conserned with
  next behavior
 2018-03-13 00:40:13 +09:00
Patrik Nordwall
a05f50a0c0 reduce boilerplate for passing setup (and [C,E,S]) 
use an enclosing class that holds the setup
 2018-03-13 00:40:13 +09:00
Konrad Malawski
ffb4419c4e WIP towards immutable style 
compiles, does not work..
 2018-03-13 00:40:13 +09:00
Johannes Rudolph
40abd2b096 Rename PersistentBehaviorImpl => EventsourcedSetup and pass setup around directly 2018-03-13 00:40:13 +09:00
Johannes Rudolph
a9293b3df2 Allow internal custom implementations of DeferredBehavior 
Pass around context for stashing
 2018-03-13 00:40:13 +09:00
Johannes Rudolph
fa05695548 separate PersistentBehavior API and implementation 2018-03-13 00:40:13 +09:00
Konrad Malawski
70e225b734 =per native typed implementation of Eventsourced=>PersistendBehavior 
timeout is explicitly a message of Command

persitAll and chainable side effects work well

more tests pasing

additional sanity check that mutable behaviors work as expected

unstashing needs to "loop through" the AdapterActor otherwise Stopped
won't work

solve unstashing/stop issue, by not randomly init()ing, but unstashing

snapshotting works

all tests green

rebased

nicer log source

remove IncomingCommand wrapper, we dont need it

no need for shared counter

remove not needed methods and state

more state cleanup, using Behaviors.same

reminder that we DO need that same alias, since stash does not work with
the Behavior.same

introduce config for stash buffer

stopping now works after persisting

compile fix

cleanup

reduced number of adapter styles needed for co-existence of persistence

final cleanup done, less passing around 40 objects, carriers provided
now
 2018-03-13 00:40:13 +09:00
Kevin Mas Ruiz
907c6a6931 Do not drop messages in delay with EmitEarly when buffer overflows (#24642) 2018-03-12 14:08:06 +01:00
Johan Andrén
f7637d24e6
Eliminate identity flow when possible #24554 2018-03-12 12:14:40 +01:00
zodiake
1a63aa8637 Update PersistenceQueryDocSpec.scala (#24405) 2018-03-12 11:59:56 +01:00
kerr
538a5a4ae6 + actor add java.time.Duration to AbstractFSM ,ActorSelection ,Scheduler and AbstractScheduler. (#24651) 2018-03-12 11:59:00 +01:00
Gaël Bréard
318c857ff0 Add serialization with transport information method in public API #24321 (#24515) 
* Add serialization with transport information method in public API #24321

Signed-off-by: Gaël Bréard <gael.breard@orange.com>

* remove copyright
 2018-03-12 11:49:14 +09:00
Johan Andrén
ac408bba8f
Revert "Unidoc directives for cluster md files" #22904 2018-03-09 10:59:49 +01:00
kerr
33ca78052c = util add Throwables helper to help fatal checking of Throwable for Java,alias with Scala's Nonfatal pattern matching. (#24661) 2018-03-09 17:13:59 +09:00
Richard Imaoka
bcc86f7703 Unidoc directives for cluster md files #22904 2018-03-09 09:12:54 +01:00
Patrik Nordwall
7d67524bb5 lazy init of SerializationExtension in Artery, #24620 (#24667) 
to avoid loading serializers before ActorRefProvider has been initialized
 2018-03-09 16:59:33 +09:00
Konrad `ktoso` Malawski
5be3c7bf83
parity for Sink, for preMaterialize operation (#24657) 
* +str #24656 parity for Sink, for preMaterialize operation

* add java test

* added docs to stages-overview
 2018-03-08 13:02:17 +09:00
Konrad `ktoso` Malawski
5a59a7b362
Revert "TCK: Empty Flow[Int]: onSubscribe should be called prior to onComplete always " (#24678) 
* Revert "deduplicate logic for IODispatcher #24604 (#24619)"

This reverts commit 0ecadf7235.

* Revert "ClusterSharding: automatically choose start or startProxy by a node role (#23934) (#24669)"

This reverts commit a13f5cab00.

* Revert "tck issue or bug,  onSubscribe should be called prior to onComplete always (#24582)"

This reverts commit d55990fa64.
 2018-03-08 11:47:16 +09:00
Roman Filonenko
0ecadf7235 deduplicate logic for IODispatcher #24604 (#24619) 
* deduplicate logic for IODispatcher #24604
 * introduce a resolveDispatcher helper in ActorAttributes
 * mention akka.stream.materializer.blocking-io-dispatcher instead of akka.stream.blocking-io-dispatcher in scaladocs
 * fix a flaky test
 * cosmetic changes in the touched files

* move resolveDispather helper to the Dispatcher companion object under a new name resolve

* filter out mima warning

* fix mima excludes after the 2.5.11 release

* address review comments
 * update stream-io.md with the correct dispatcher config key
 * mark ActorAttributes.Dispatcher#resolve as internal API
 * use the dispatche config key in ActorMaterializer

* add private[akka] to the resolve methods
 2018-03-07 15:12:34 +01:00
Patrik Nordwall
a13f5cab00 ClusterSharding: automatically choose start or startProxy by a node role (#23934) (#24669) 2018-03-07 13:17:56 +09:00
Konrad `ktoso` Malawski
d55990fa64
tck issue or bug, onSubscribe should be called prior to onComplete always (#24582) 2018-03-07 13:05:14 +09:00
Johan Andrén
2df4898f53 Fix a few leftover Behaviors.deferred mentions (#24612) 2018-03-06 10:04:17 +09:00
kerr
97ca714d17 = all remove semicolons "bye-bye semicolon" (#24659) 2018-03-06 09:53:28 +09:00
Francisco José Bermejo Herrera
6646eded2c Add serializer for akka.NotUsed (#24599) (#24600) 2018-03-05 17:38:17 +01:00
Patrik Nordwall
d9249226c0
Merge pull request #24653 from shkoder/fix-trigger-in-digest-cookbook 
fix Trigger references in the stream cookbook example for digest #24317
 2018-03-05 17:36:51 +01:00
Johannes Rudolph
0da4762073
Merge pull request #24552 from RafalSumislawski/24544-name-affinity-pool-threads 
#24544 Add dispatcher name to names of threads created by AffinityPool
 2018-03-05 17:18:00 +01:00
Yan Su
519e6ae546 Add java duration support for Source.tick (Java DSL) #24339 (#24645) 2018-03-05 17:13:15 +01:00
Patrik Nordwall
0ea8c0d872
Merge pull request #24592 from akka/wip-24576-LargeMessageClusterSpec-patriknw 
slowdown LargeMessageClusterSpec for tcp transport, #24576
 2018-03-05 16:20:46 +01:00
Patrik Nordwall
1c8a2945ab slowdown LargeMessageClusterSpec for tcp transport, #24576 2018-03-05 15:19:12 +01:00
Thomas Smith
c9969b0bea Add log() method to typed Logging API #24648 2018-03-05 09:10:14 +01:00
Roman Filonenko
8fcf728b7a fix Trigger references in the stream cookbook example for digest #24317 
* replace Trigger with Unit
 * cosmetic changes in docs.stream.cookbook tests
 2018-03-03 08:52:02 +01:00
Konrad Malawski
1574faf180 +ben add DirectBufferPoolBenchmark, just for reference 2018-03-01 22:16:18 +09:00
Richard Imaoka
82f50a848a Add unidoc directive for markdowns #24426 2018-03-01 13:35:00 +01:00
Ignasi Marimon-Clos
3de7a4c27c Adds test and caps the timeout check period to 1s #24616 2018-03-01 11:47:02 +01:00
Johan Andrén
c9ff3cbf80
MiMa latest release updated (#24638) 2018-03-01 10:48:40 +01:00
Josep Prat
4661ee03cf Fixes broken test for Scala 2.12 #24617 
Refs: #24617
Fixes tests for Scala 2.12.x
There are still some differences between 2.11 and 2.12
 2018-03-01 17:25:09 +09:00
adamlehenbauer
ba15b72714 Fix typo: lead -> led 2018-03-01 11:42:39 +09:00
Song Kun
32021cb382 =doc fix the wrong position of a sentence 2018-03-01 11:32:05 +09:00
Johan Andrén
b7cc50cdd6
2.5.10 wire protocol regression (#24625) 2018-02-28 09:46:37 +01:00
Ignasi Marimon-Clos
58c00b67e5 Remove "them them" (#24613) 2018-02-23 14:05:54 +01:00
Patrik Nordwall
9330969450
Merge pull request #24611 from akka/wip-minor-tcp-doc-patriknw 
small adjustment of the aeron vs tcp documentation
 2018-02-23 11:32:01 +01:00
Filip
cdc0fd3e3d Avoid infinite recursion in AbstractPersistentFSM, #24448 2018-02-23 10:50:32 +01:00
Patrik Nordwall
cf312703fa small adjustment of the aeron vs tcp documentation 2018-02-23 10:41:21 +01:00
Patrik Nordwall
488c22561f
Merge pull request #24606 from akka/wip-deprecated-blocking-io-dispatcher-patriknw 
fix blocking-io-dispatcher setting, #24357
 2018-02-22 19:11:00 +01:00
Patrik Nordwall
8a662bdc24 fix deployRsync param in release script 2018-02-22 18:06:37 +01:00
Patrik Nordwall
cd95979ed7 fix blocking-io-dispatcher setting, #24357 
It must still have a valid value becuase used from Akka HTTP.
 2018-02-22 18:03:08 +01:00
Johan Andrén
fd6f30673a Actually use the relative blocking io dispatcher setting #24357 
* Remove docs and have only deprecation comment on old setting
* ConfigFactory.load fixed
 2018-02-22 13:42:59 +01:00