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

22637 commits

This branch
This branch
All branches
Author SHA1 Message Date
Christopher Batey
403752ab65 Upgrade to Aeron 1.11 2018-10-05 10:32:56 +01:00
Matt Kohl
c89b4a1884 Documentation fixes (#25725) 
* tread -> thread
 2018-10-04 10:37:42 +02:00
Patrik Nordwall
272cceb12b
Merge pull request #25593 from akka/wip-25592-terminated-patriknw 
hardening of CoordinatedShutdown init, #25592
 2018-10-03 16:54:55 +02:00
Christopher Batey
ba67f71ca8 Treat MemberStatus.Removed as terminal state in ClusterReadView (#25499) 
* Fixes #25489 where cluster event for a previous state can override
the call to cluster.close settings it to remove
* Fix case where Removed is used as a placeholder for unknown
 2018-10-03 14:01:38 +02:00
Johan Andrén
1d65159923
Merge pull request #25538 from jchapuis/zipLatest 
zipLatest and zipLatestWith operators (refs #25392)
 2018-10-03 11:28:43 +02:00
Johan Andrén
4a1d26357f
Merge pull request #25716 from vhiairrassary/patch-2 
Remove duplicated section in doc
 2018-10-03 07:21:42 +02:00
Johan Andrén
55afc12717
Merge pull request #25715 from nvollmar/master 
Removing deprecation mark for method without maximum restart attempts #25714
 2018-10-03 07:21:03 +02:00
Jonas Chapuis
2332226358 fix similar race in another test 2018-10-02 23:59:53 +02:00
Jonas Chapuis
7c264a9748 support up to 22 inputs as per spec and fix race in test 2018-10-02 22:37:14 +02:00
Jonas Chapuis
375c1f8365 add additional coverage for possible case 2018-10-02 22:34:13 +02:00
Jonas Chapuis
41c59fdf48 change semantics of ZipLatest slightly to account for pending first tuple with subsequent completion 2018-10-02 18:50:44 +02:00
Johan Andrén
ec82119a94
Merge pull request #25723 from akka/arteryTests 
Specify the artery port '0' to avoid address already in use
 2018-10-02 18:06:54 +02:00
Saleh Khazaei
68e382c7f9 Add examples for zipWithIndex #25468 (#25661) 
* Add examples for zipWithIndex #25468

* better examples
 2018-10-02 16:56:26 +02:00
Arnout Engelen
0101740825 Fix parsing truncated DNS messages (#25691) 
* Fix parsing truncated DNS messages

* Additional validations
 2018-10-02 16:52:28 +02:00
Patrik Nordwall
68074c3deb
Merge pull request #25694 from chbatey/mima2517 
Mima latest version to 2.5.17
 2018-10-02 16:44:20 +02:00
Arnout Engelen
e822b69f82 Specify the artery port '0' to avoid address already in use 2018-10-02 15:30:41 +02:00
Victor Hiairrassary
7b08de5d46
Remove duplicated section in doc 2018-10-02 09:05:58 +02:00
Nicolas Vollmar
be85b1b9a5 Removing deprecation mark for method without maximum restart attempts #25714 2018-10-02 08:44:23 +02:00
Johan Andrén
5b9bc0360f
Merge pull request #25693 from chbatey/scala2127 
Upgrade to scala 2.12.7
 2018-09-28 10:58:28 +02:00
Johan Andrén
081e6bd8ba Document MutableBehavior (#25685) 
* Document MutableBehavior #25631
 2018-09-28 06:50:00 +01:00
Arnout Engelen
9a54ae92d5 Support IPv6 in async-dns (#25687) 
* Support IPv6 in async-dns

* Expect AAAA records for IPv6
 2018-09-28 06:41:07 +01:00
Christopher Batey
c3ca5afb97 Mima latest version to 2.5.17 2018-09-27 17:11:27 +01:00
Christopher Batey
9a5b163630 Upgrade to scala 2.12.7 2018-09-27 16:08:09 +01:00
Patrik Nordwall
6464dea52b
Merge pull request #25595 from akka/wip-25336-orset-actorref-patriknw 
Revert Support for rolling upgrade of ORSet[ActorRef], #25336
 2018-09-26 14:21:00 +02:00
Patrik Nordwall
2016368612
Merge pull request #25684 from akka/wip-25683-revert-computeIfAbsent-patriknw 
Revert "Avoid ask to sharding guardian if region already cached", #25683
 2018-09-26 13:31:25 +02:00
Patrik Nordwall
d65a90b688
Merge pull request #25678 from akka/wip-25632-down-Terminated-patriknw 
Don't automatically down quarantined node, #25632
 2018-09-26 13:30:23 +02:00
Patrik Nordwall
fd0153a090 Revert "Avoid ask to sharding guardian if region already cached", #25683 
* revert a7656ab8c4a93a3fe8af7a22690cb33f7a280af5
* test for reproducing the issue with computeIfAbsent
* use non-blocking get as optimization for avoiding ask
 2018-09-26 12:05:16 +02:00
Patrik Nordwall
4b7f05b280
Merge pull request #25645 from akka/wip-AskTimeoutException-patriknw 
Improve AskTimeoutException message, #25644
 2018-09-26 11:32:53 +02:00
Johan Andrén
0a98361e26
Merge pull request #25682 from cjtraverso/patch-1 
Update Akka Bootstrap URL
 2018-09-26 10:26:13 +02:00
Patrik Nordwall
f2ad055c77 Improve AskTimeoutException message, #25644 2018-09-26 08:00:11 +02:00
Cristian
bbe9069d48
Update Akka Bootstrap Url 2018-09-25 17:18:42 -03:00
Cristian
b02ad6707a
Update Akka Cluster Bootstrap url 
Currently the url is: https://developer.lightbend.com/docs/akka-management/current/bootstrap.html
It should be changed to: https://developer.lightbend.com/docs/akka-management/current/bootstrap/index.html
 2018-09-25 17:13:10 -03:00
Patrik Nordwall
5a4ec8a557
Merge pull request #25679 from akka/wip-monitor-api-patriknw 
+str #24812 fix signature of monitor()
 2018-09-25 16:24:35 +02:00
Christopher Batey
23b9266fca
Provide minSequenceNr for snapshot deletion (#25590) 
* Provide minSequenceNr for snapshot deletion

Journals can use this to make the bulk deletion more efficient

Use keepNrBatches to delete the last few snapshots in case previous
deletes failed.
 2018-09-25 13:38:18 +01:00
Christopher Batey
d7c463e033
Only treat nameservers as a StringList in config if getting as String… (#25636) 
* Only treat nameservers as a StringList in config if getting as String fails
 2018-09-25 13:36:01 +01:00
Konrad Malawski
f9911facc0 +str #24812 fix signature of monitor() 
* make monitor be a keep.both by default
 2018-09-25 09:29:51 +02:00
Tzu-Chiao Yeh
f06595dd5d Add and reuse example for FileIO stream operator. (#25660) 2018-09-24 17:50:27 +02:00
Patrik Nordwall
a6737b5e42 Don't automatically down quarantined node, #25632 2018-09-24 14:05:13 +02:00
Johan Andrén
83b30f1ed2
Merge pull request #25653 from chbatey/supervision-interceptor 
Supervision with a BehaviorInterceptor
 2018-09-24 09:44:36 +02:00
Patrik Nordwall
0478d242e1
AccountExample in javadsl, #25485 (#25505) 2018-09-21 15:37:13 +02:00
Johan Andrén
16438fcb86 Deduplicate is specific to interception so belongs where it is #25599 (#25665) 2018-09-21 15:28:03 +02:00
Johan Andrén
8c058678ca Disallow nested mixed widen usages, #25604 2018-09-21 15:24:01 +02:00
Christopher Batey
63e00634d4 Warning for truncated DNS messages (#25666) 
* Log warning if DNS response truncated
* Docs msg
 2018-09-21 15:19:37 +02:00
Patrik Nordwall
546f1634c9
Merge pull request #25610 from akka/wip-24463-EntityRef.ask-patriknw 
Introduce RecipientRef interface for ActorRef and EntityRef, #24463
 2018-09-21 15:16:18 +02:00
Patrik Nordwall
824e4196e7 Introduce RecipientRef interface for ActorRef and EntityRef, #24463 
* to make it possible to use ActorContext.ask also with EntityRef
  destinations
* this abstraction will probably be useful for other things, where a
  full ActorRef is not required
* a RecipientRef only has to support tell (and ask), while a full ActorRef
  is watchable (destination has a lifecycle) and location transparent (serializable)
 2018-09-21 14:39:18 +02:00
Patrik Nordwall
6d8d646fe5
Merge pull request #25539 from akka/wip-25480-sharding-start-patriknw 
Simplify signature of ClusterSharding.spawn, #25480
 2018-09-21 14:21:33 +02:00
Johan Andrén
a8cfe1e0ff
Merge pull request #25654 from johanandren/wip-25620-remove-typed-persistence-ctx-param-johanandren 
Remove the ActorContext parameter from the scaladsl command handler
 2018-09-21 13:51:09 +02:00
Johan Andrén
10fc413238 Some usages of the removed signatures 2018-09-21 10:34:41 +02:00
Jonas Chapuis
a098e0b743 add zipLatest and zipLatestWith operators and graphstages 2018-09-21 09:51:28 +02:00
Christopher Batey
5ad6f2c568 Review: Don't double log exception 2018-09-20 16:37:26 +01:00