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

661 commits

Author SHA1 Message Date
Jakub Czuchnowski
1d36879e53 Add missing for Custom Stream Processing docs #25940 (#25941) 2018-11-19 10:29:10 +01:00
Helena Edelson
f872115512 Cluster event listener that logs all events #25832 (#25918) 2018-11-15 17:31:58 +01:00
Arnout Engelen
40649151d0 Document docker resource limits (#25925) 
* Document docker resource limits

* No longer experimental on JVM10
 2018-11-15 15:48:57 +00:00
Oliver Burkhalter
40483a2506 Improve Getting Started Guide Part 3 for writing a first Actor test #25193 2018-11-15 12:55:29 +01:00
Roman Filonenko
d0feb5f28e fix non-@ref tag in serialization (#25900) (#25901) 2018-11-13 10:06:49 +01:00
kerr
e847ce016a +act add getEventStream to ActorSystem #25870 2018-11-09 12:29:05 +01:00
Philippus Baalman
90bf989630 Replace scalactic deprecations (#25886) 2018-11-09 09:07:21 +01:00
Christopher Batey
847a7c1afd Add warning about nsswitch to dns docs (#25889) 2018-11-09 09:06:17 +01:00
Patrik Nordwall
70176341d9
Merge pull request #25847 from chbatey/dns-warn 
Warn about async-dns lack of support for search domains
 2018-11-07 12:36:00 +01:00
Patrik Nordwall
4d115f19a6 rename ClusterSharding start to init, #25711 (#25867) 
* rename ClusterSharding start to init, #25711

* fix test
 2018-11-06 19:43:55 +01:00
Patrik Nordwall
9c1153b1a6 Make the stop message in sharding optional, #25642 
* It's mostly technical concern that is blurring the business logic in the entity
* Async interactions before stopping is often not needed
* Implemented with an internal PoisonPill signal that is added by sharding,
* Persistent actors handle PoisonPill and run side effects after persist
  and process stashed messages before stopping.

* remove unecessary stop messages

* reference docs
 2018-11-06 19:43:55 +01:00
Johan Andrén
133c41375f Automatic passivation for typed sharding, #25512 2018-11-06 19:15:23 +01:00
Dale Wijnand
9941f7d800 Consistently bind ActorContext to 'context' in the docs (#25852) 
* Consistently bind ActorContext to 'ctx' in the docs

... over the lesser uses 'context':

    $ rg 'Behavior[s]?.setup' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg ctx | wc -l
          59
    $ rg 'Behavior[s]?.setup' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg context | wc -l
           8
    $ rg 'Behavior[s]?.receive' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg ctx | wc -l
          66
    $ rg 'Behavior[s]?.receive' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg context | wc -l
           5

* Fix "variable ctx is already defined" warnings

* Replace ctx with context, in docs & doc snippets

    fastmod '\bctx\b' 'context' \
        akka-docs/src/main/paradox/typed
        akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala \
        akka-actor-typed-tests/ \
        akka-actor-testkit-typed/ \

* Replace msg with message, in docs & doc snippets

    fastmod '\bmsg\b' 'message' \
        akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala \
        akka-actor-typed-tests/ \
        akka-actor-testkit-typed/
        akka-docs/src/main/paradox/typed/

* Fix code alignment
 2018-11-05 13:53:18 +00:00
Christopher Batey
e242927d76 Warn about async-dns lack of support for search domains 2018-11-01 09:55:47 +00:00
kerr
fafc59b19d update headers to regular comment (#25807) 2018-10-29 05:19:37 -04:00
mohammad mehdi
ba996f8c5f example for some sink operators #25468 
Examples for takeLast, last and lastOption operators
 2018-10-25 09:40:36 -04:00
Saleh Khazaei
91b0c387be Add examples for Fan-in operators #25468 2018-10-25 09:37:48 -04:00
Patrik Nordwall
4479046d1e fix cluster routing docs (#25810) 
* broke when it was moved to separate page
 2018-10-24 08:13:43 -04:00
Patrik Nordwall
abb3429bc8
Merge pull request #25804 from akka/wip-25750-AbstractBehavior-patriknw 
Rename MutableBehavior to AbstractBehavior, #25750
 2018-10-18 13:16:48 +02:00
Patrik Nordwall
2672bd7a95 PersistentEntity to glue together Sharding and PersistentBehavior better 
* Makes the combination more visable
* You don't have to worry about the persistenceId, only EntityTypeKey and entityId
* The glue is stronger in the javadsl because of two reasons
  * Couldn't realisticly create a PersistentEntity class extending PersistenBehavior (which
    contains all the optional parameters and functions) since that would duplicate too much.
  * The ActorContext would be needed in the ShardedEntityContext parameter and because of the
    additional M type parameters the type inference breaks down when using the factory. Would
    require specifying the type of the ShardedEntityContex[M] parameter. That problem doesn't
    seem to exist in Java.

renamed:
s/ShardedEntityContext/EntityContext/
s/ShardedEntity/Entity/
 2018-10-18 11:47:51 +02:00
Patrik Nordwall
1691961a10
AccountExample in Scala in a few flavors, #25485 
* AccountExample in Scala in a few flavors
* include Account examples in reference docs
* cleanup BlogPost example
* include reply doc snippets
 2018-10-18 11:37:06 +02:00
Patrik Nordwall
81c7adf4a1 thenReply Effect, #25482 
* enforce ReplyEffect
 2018-10-17 14:02:16 +02:00
Patrik Nordwall
ad3ad15747 Rename MutableBehavior to AbstractBehavior, #25750 
* Also cleanup javadsl Receive, which is only used from AbstractBehavior
* Clarify further in docs that the functional vs OO style is a matter of taste
 2018-10-17 08:53:37 +02:00
Patrik Nordwall
d71ba251ed make java sample code independent of Scala (#25800) 
* need this for gathering and compiling java sources (in IDE),
  https://github.com/patriknw/akka-compile-ide-java
 2018-10-16 13:52:54 +01:00
J Evans
e7347ffee4 grammar nit (#25791) 2018-10-15 23:13:07 +02:00
Patrik Nordwall
b89a7e5df5 Use Props factory methods in getting started tutorial (#25713) 
* Use Props factory methods in getting started tutorial

* deprecate Props.create without actorClass parameter, #25718
 2018-10-15 17:12:41 +01:00
Arnout Engelen
4b012cc306 Document 'withBackoff' srouce/flow/sink (#25770) 2018-10-15 17:11:33 +01:00
Renato Cavalcanti
8e0b9b58e2 fixed typo in DNS extension documentation (#25789) 2018-10-12 18:16:00 +01:00
Johan Andrén
b0de255d27 Docs for typed distributed data (#25747) 
* Typed distributed data docs shaping up
 2018-10-12 08:14:01 +01:00
Patrik Nordwall
d9af08757e rename PersistentBehaviors.receive to PersistentBehavior.apply 2018-10-09 13:47:22 +02:00
mohammad mehdi
918cb72594 example for reduce operator #25468 2018-10-08 16:15:33 +02:00
Oliver Wickham
ef08bbd74b Fix doc links to cluster docker compose sample (#25756) 2018-10-08 15:33:46 +02:00
Christopher Batey
2045a0fbf7 Clarify supervision of singleton actors (#25681) 
* Clarify supervision of singleton actors
* Document supervision for typed singletons
 2018-10-08 14:42:18 +02:00
Matt Kohl
c89b4a1884 Documentation fixes (#25725) 
* tread -> thread
 2018-10-04 10:37:42 +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
Saleh Khazaei
68e382c7f9 Add examples for zipWithIndex #25468 (#25661) 
* Add examples for zipWithIndex #25468

* better examples
 2018-10-02 16:56:26 +02:00
Victor Hiairrassary
7b08de5d46
Remove duplicated section in doc 2018-10-02 09:05:58 +02:00
Johan Andrén
081e6bd8ba Document MutableBehavior (#25685) 
* Document MutableBehavior #25631
 2018-09-28 06:50:00 +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
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
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
Tzu-Chiao Yeh
f06595dd5d Add and reuse example for FileIO stream operator. (#25660) 2018-09-24 17:50:27 +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
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
Jonas Chapuis
a098e0b743 add zipLatest and zipLatestWith operators and graphstages 2018-09-21 09:51:28 +02:00
Johan Andrén
f8d182574a Remove CommandHandler.byState #25655 2018-09-20 16:15:55 +02:00
Johan Andrén
5d129a804b Docs sample of accessing context from persistent behavior 2018-09-20 15:45:16 +02:00