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

22573 commits

This branch
This branch
All branches
Author SHA1 Message Date
Christopher Batey
9a5b163630 Upgrade to scala 2.12.7 2018-09-27 16:08:09 +01:00
Patrik Nordwall
2a5f254f16
Merge pull request #25225 from akka/wip-24478-passivate-patriknw 
WIP: Passivate for Typed Sharding, #24478
 2018-09-20 11:05:15 +02:00
Patrik Nordwall
0f56a6d1ed Passivate for Typed Sharding, #24478 
* also moved singleton doc sample to own file
* and mv /doc/ to /docs/ as in other places
 2018-09-20 11:04:32 +02:00
Konrad `ktoso` Malawski
bf3c11464e
add usage examples for conflate / conflate with seed (#25498) 
* +doc conflate and conflateWithSeed docs examples

* fixes

* show throttle in the example so its more obvious that "slow upstream" etc
 2018-09-20 16:22:11 +09:00
Johan Andrén
4206e16954
Merge pull request #25565 from johanandren/wip-down-removal-margin-take-two-johanandren 
Undeprecate the config, add a note in cluster singleton
 2018-09-20 09:03:34 +02:00
Konrad `ktoso` Malawski
1d709ac718
=doc #24283 include rationale for Sink Source not extending RS (#24286) 
* Document reasons why Akka Streams are not IS-A with RS interfaces

* amended
 2018-09-20 13:27:14 +09:00
Konrad `ktoso` Malawski
d0d54212dd
add TODOs to encourage contributing operator examples (#25478) 2018-09-20 13:01:24 +09:00
Johan Andrén
cc0705483b Clarify that there should normally be only one ActorSystem (#25641) 2018-09-19 13:25:14 +02:00
Patrik Nordwall
63ceb52bbd Use supervision in all places of Source.fromIterator, #25574 (#25601) 
* it was noticed in Source.fromIterator depending on where the
  iterator throwed exception
* fromIterator, as many other things, is implemented with
  statefulMapConcat
* supervision was only used for exceptions in onPush and not
  in onPull, added it there also
 2018-09-19 18:06:24 +09:00
Justin Pihony
e73bc64ade Add deprecation documentation to bin-compat docs (#25400) 
* Add deprecation documentation to bin-compat docs

Closes #25399

* Be more flexible and change version type
 2018-09-19 16:12:02 +09:00
Patrik Nordwall
c9ea0309c9
Merge pull request #25563 from akka/wip-manifest-version-patriknw 
Utility to check that same version of all modules is used
 2018-09-18 19:50:35 +02:00
Patrik Nordwall
82bcbb68d2
Merge pull request #25572 from akka/wip-25481-EntityRef-scheduler-patriknw 
Remove Scheduler param in EntityRef.ask, #25481
 2018-09-18 19:48:59 +02:00
Patrik Nordwall
311959ed04
Merge pull request #25633 from akka/wip-more-intercept-test-patriknw 
Some more BehaviorIntercept tests
 2018-09-18 19:47:24 +02:00
Patrik Nordwall
af2d15a188 Some more BehaviorIntercept tests 
* filter messages
* show how it can be used to implement PoisonPill
 2018-09-18 17:13:09 +02:00
Patrik Nordwall
e20b0287fd Utility to check that same version of all modules is used 
* Stolen from Cinnamon
* Can be used from outside of Akka, e.g. Akka HTTP or Lagom
 2018-09-18 13:50:39 +02:00
Patrik Nordwall
e62240b4b3
Merge pull request #25638 from jrudolph/fix-docs 
Docs: don't use $code$ for now in doc snippets
 2018-09-18 13:01:36 +02:00
Johannes Rudolph
a84a18d262
Docs: don't use $code$ for now in doc snippets 2018-09-18 12:48:03 +02:00
Patrik Nordwall
83c7894514
Merge pull request #25586 from akka/wip-24598-testkit-patriknw 
ActorTestKit overhaul, #24598
 2018-09-18 11:23:15 +02:00
Richard S. Imaoka
5dd487311d Add more description about ClusterEvent.InitialStateAsSnapshot (Closes #25172) 2018-09-18 14:56:26 +09:00
Christopher Batey
1d0603dab9 make scalatest suite type agnostic 2018-09-17 17:54:54 +02:00
Patrik Nordwall
b16e4d5e4d ActorTestKit overhaul, #24598 
* composition is the basic building block for ActorTestKit
* ActorTestKitWordSpec for integration with ScalaTest
  (automatic shutdown)

* Use ActorTestKitWordSpec in our own tests

* doc TestException
 2018-09-17 17:00:15 +02:00
kerr
ffc08d0b7a update to sbt 1.2.3 (#25626) 2018-09-17 11:19:48 +01:00
Christopher Batey
8ba4de386f
Document async and inetaddress DNS (#25414) 
* Document async and inetaddress DNS

Closes #25307
 2018-09-17 08:11:34 +01:00
Patrik Nordwall
c132a81f0a
Merge pull request #25152 from gabfssilva/master 
Add method foreachAsync to Sink object
 2018-09-14 17:50:57 +02:00
Gabriel
a679f6f59e Add method foreachAsync to Sink object 2018-09-14 11:42:29 -03:00
Patrik Nordwall
ed951ccede
Merge pull request #25522 from akka/wip-25502-outport-diagram-patriknw 
fix initial state of output port transitions, #25502
 2018-09-14 16:25:12 +02:00
Patrik Nordwall
f49a483582
Merge pull request #25526 from jczuchnowski/fix-25525-stream-docs-imports 
Add missing imports for Custom stream processing docs #25525
 2018-09-14 16:24:05 +02:00
Patrik Nordwall
5371aa17e4 cleanup some systemActor stuff (#25606) 
* remove the ActorRef.apply(Future) since that is uncertain, see ticket #25305
 2018-09-14 14:18:47 +01:00
Patrik Nordwall
d8857e8d2a fix fiddle snippet path (#25621) 2018-09-14 14:17:34 +01:00
Arnout Engelen
e2c443b40f Allow restarting a named child in StubbedActorContext 2018-09-14 14:39:08 +02:00
Saleh Khazaei
176b718b2a Adding maximum restart attempts to BackoffSupervisor #24769 2018-09-14 14:22:52 +02:00
Johan Andrén
0d7419b422
Merge pull request #25562 from andreaTP/akkaTypedFiddle 
+doc Adding a fiddle example for Akka Typed
 2018-09-14 09:55:58 +02:00
Enno
c759fcf91d Logging docs: show akka-slf4j dependency (#25588) 2018-09-13 12:13:24 +01:00
Enno
3eb9b3a1a6 Use absolute snippet paths (#25607) 
* Support absolute snippet path in signature directive

* Removed $ akka $ from snippet paths

* Remove $ code $ snippet alias

* Remove $ code $ snippet prefix
 2018-09-13 10:49:51 +02:00
Patrik Nordwall
a1b4ac7c8e
Merge pull request #25603 from ennru/ennru_paradox-4.2 
Upgrade to akka-paradox 0.12
 2018-09-12 15:10:53 +02:00
Johan Andrén
ab63fe037c Add BehaviorInterceptor and a more general way to traverse the behavior stack, #25504 
* All nesting behaviors covered with an id parameter
* All wrapping behaviors except supervision replaced with new Intercept implementation
* Implement widen in terms of BehaviorInterceptor
* pass ctx to avoid allocation
 2018-09-12 13:03:17 +02:00
Enno Runne
5f42ea1dc1 Upgrade to akka-paradox 0.12 2018-09-12 12:53:46 +02:00
Konrad `ktoso` Malawski
84deea70f6
=doc Explain cgroup memory limit flags for docker (#25591) 
* =doc Explain cgroup memory limit flags for docker

* Update deploy.md
 2018-09-11 14:14:02 +09:00
Patrik Nordwall
9cb46763d3
Merge pull request #25554 from akka/wip-mima-2.5.16-patriknw 
Mima latest version 2.5.16
 2018-09-10 16:27:13 +02:00
Patrik Nordwall
116dbadda7 Mima latest version 2.5.16 2018-09-10 15:37:21 +02:00
Enno
91240880b8 Docs: use the latest name to refer to Alpakka Kafka Connector (#25589) 2018-09-10 18:41:46 +09:00
Johan Andrén
99f9adbaad
Fix bad link to Immutability Changes Everything 2018-09-07 15:10:42 +02:00
Odd Möller
127806694e
Fix bad link to Immutability Changes Everything 
The current link (http://www.cidrdb.org/cidr2015/Papers/CIDR15_Paper16.pdf) returns 404, removing 'www' (http://cidrdb.org/cidr2015/Papers/CIDR15_Paper16.pdf) returns the correct PDF.
 2018-09-07 11:58:40 +02:00
Konrad `ktoso` Malawski
38c6276580
=str #25469 stream refs hardened termination via awaiting completion signal (#25561) 
* =str #25469 stream refs hardened termination via awaiting completion

* review comments
 2018-09-07 16:19:56 +09:00
Christopher Batey
135bd5b9ed
Build with 2.12 as default (#25515) 
* Travis builds 2.11 and 2.12 to catch issues

Closes #25514
 2018-09-07 07:27:43 +01:00
Patrik Nordwall
64fa8f5ccd Remove Scheduler param in EntityRef.ask, #25481 2018-09-06 09:52:25 +02:00
Johan Andrén
f12f686120
Balance - downstream waits for a response indefinitely #25387 2018-09-05 12:56:42 +02:00
Patrik Nordwall
1f31024144
Merge pull request #25542 from akka/wip-25034-abs-patriknw 
fix negative math.abs in Sharding Typed, #25034
 2018-09-05 12:04:17 +02:00
Johan Andrén
8ed4f5abab Undeprecate the config, add a note in cluster singleton 2018-09-04 14:21:25 +02:00
andrea
1fdf8155c3 +doc Adding a fiddle example for Akka Typed 2018-09-03 15:48:14 +01:00