Commit graph

601 commits

Author SHA1 Message Date
Konrad Malawski
1cf22f50ae Merge pull request #17889 from ktoso/doc-eventStream-subclass-ktoso
+doc #17877 document filtering for subclasses in eventStream
2015-07-03 00:51:18 +02:00
Patrik Nordwall
664ae2f8f5 Merge pull request #17869 from akka/wip-17447-split-docs-patriknw
=cls #17447 Split Cluster Sharding and Tools docs into java/scala
2015-07-02 22:39:50 +02:00
Patrik Nordwall
38faafc494 =clt #17447 Split ClusterClient docs into java/scala 2015-07-02 20:14:01 +02:00
Patrik Nordwall
16620d9f83 Merge pull request #17879 from akka/wip-16897-doc-patriknw
=clu #16897 Correct wording for routees.paths
2015-07-02 19:59:27 +02:00
Patrik Nordwall
49264c0f83 Merge pull request #17864 from akka/wip-17779-ddata-activator-patriknw
=cdd #17779 Create activator template for Distributed Data
2015-07-02 17:49:50 +02:00
Konrad Malawski
7eeaf6cd9f =doc remove duplicated word typos 2015-07-01 23:48:17 +02:00
Konrad Malawski
0e8dd3a7f4 +doc #17877 document filtering for subclasses in eventStream 2015-07-01 23:17:21 +02:00
Patrik Nordwall
7bd9550e3b =clu #16897 Correct wording for routees.paths 2015-07-01 16:19:49 +02:00
Christopher Batey
8e6df0d322 =doc update references to deferAsync 2015-07-01 10:46:34 +01:00
Patrik Nordwall
6e28229fbe =clt #17447 Split DistributedPubSub docs into java/scala 2015-06-30 16:39:32 +02:00
Patrik Nordwall
a93de9bf37 =clt #17447 Split Cluster Singleton docs into java/scala 2015-06-30 16:39:32 +02:00
Patrik Nordwall
89f17ddfd0 =cls #17447 Split Cluster Sharding docs into java/scala 2015-06-30 16:39:31 +02:00
Konrad Malawski
33fbfec222 !per,doc,sam #17574 #17626 make recovery a method, move lambda samples
+ LambdaDoc samples now in the docs project
= simplified internal state by removing recoveryPending
= recovery is now triggered in around* method, so user is free to use
  preStart freely - recovery works even if one forgets to call super on
  preStart
2015-06-30 16:01:52 +02:00
Patrik Nordwall
252e88c082 =cdd #17779 Create activator template for Distributed Data
* includes the samples, with tutorial text description
2015-06-30 08:08:43 +02:00
Patrik Nordwall
ee9137db4d =cdd #17851 Mark distributed data as experimental 2015-06-26 15:31:49 +02:00
Konrad Malawski
83e931ea7e Merge pull request #17828 from ktoso/wip-nested-persist-ktoso
~per #15640 support nested persist calls
2015-06-26 12:53:16 +02:00
Patrik Nordwall
77df1372ad +per #17799 Fix refactoring bug in deleteMessages
* add missing test
* use DeleteMessagesFailure and add onDeleteMessagesFailure (logging)
2015-06-26 12:05:38 +02:00
Konrad Malawski
a59c9f73b6 =per #15640 support nested persist/persistAsync 2015-06-26 10:54:32 +02:00
Patrik Nordwall
4638f5630e !per #17832 Remove SyncWriteJournal 2015-06-26 07:12:11 +02:00
Patrik Nordwall
6eea0ddae6 !per #17799 Remove support for non-permanent deletes
* The permanent flag in deleteMessages
* old records stored with deletion flag are still not
  replayed
2015-06-25 15:43:45 +02:00
Patrik Nordwall
8c47e01e9d !per #15377 Mandate atomic writes for persistAll, and support rejections
* changing Plugin API for asyncWriteMessages and writeMessages
* passing explicit AtomicWrite that represents the events of
  persistAll, or a single event from persist
* journal may reject events before storing them, and that
  will result in onPersistRejected (logging) and continue in the
  persistent actor
* clarified the semantics with regards to batches and atomic writes,
  and failures and rejections in the api docs of asyncWriteMessages
  and writeMessages
* adjust the Java plugin API, asyncReplayMessages, doLoadAsync
2015-06-25 15:28:37 +02:00
Konrad Malawski
2a5161ff6f !per #17755 removes the saved callback in plugins and adds receive 2015-06-25 13:44:03 +02:00
Konrad Malawski
63baaf1b2b !per #17586 async snapshot delete and remove timestamp from deleteSnapshot() 2015-06-25 10:19:55 +02:00
Konrad Malawski
7e86dac542 +per #17579 #17617 Introduces EventAdapter
+ per plugin scoped adapters
+ could be swapped during runtime
+per EventAdapter now has manifest and is configurable ai la serializers
+ json examples in docs
+ including "completely manual" example in case one wants to add
  metadata TO the persisted event
+ better error reporting when misconfigured bindings
+ manifest is handled by in memory plugin
- did not check if it works with LevelDB plugin yet
> TODO: json example uses Gson, as that's simplest to do, can we use
+per allows 1:n adapters, multiple adapters can be bound to 1 class
2015-06-23 16:57:43 +02:00
Konrad Malawski
5679dc8ae5 Merge pull request #17780 from hseeberger/fix-grammar-akka-typed-docs
Fix grammar in Akka Typed docs
2015-06-18 19:05:14 +02:00
Heiko Seeberger
9befb86b0f Fix grammar in Akka Typed docs 2015-06-18 19:03:37 +02:00
Christopher Hunt
7041c76ba9 +cdd #16799 Add ORMultiMap data type 2015-06-18 16:17:53 +02:00
Patrik Nordwall
cbe5dd2cf5 +cdd #16799 Add Distributed Data module
Previously know as [patriknw/akka-data-replication](https://github.com/patriknw/akka-data-replication),
which was originally inspired by [jboner/akka-crdt](https://github.com/jboner/akka-crdt).

The functionality is very similar to akka-data-replication 0.11.

Here is a list of the most important changes:

* The package name changed to `akka.cluster.ddata`
* The extension was renamed to `DistributedData`
* The keys changed from strings to classes with unique identifiers and type information of the data values,
  e.g. `ORSetKey[Int]("set2")`
* The optional read consistency parameter was removed from the `Update` message. If you need to read from
  other replicas before performing the update you have to first send a `Get` message and then continue with
  the ``Update`` when the ``GetSuccess`` is received.
* `BigInt` is used in `GCounter` and `PNCounter` instead of `Long`
* Improvements of java api
* Better documentation
2015-06-18 15:58:22 +02:00
Patrik Nordwall
b7297e2887 Merge pull request #17696 from akka/wip-15410-singleton-name-patriknw
!clt #15410 Change path in ClusterSingletonProxy.props
2015-06-18 12:45:22 +02:00
Patrik Nordwall
40252f2cd4 Merge pull request #17634 from akka/wip-16524-rm-PersistenceFailure-patriknw
!per #16524 Make persistent failures fatal
2015-06-18 11:33:42 +02:00
Patrik Nordwall
23c28af469 !clt #15410 Change path in ClusterSingletonProxy.props
* to avoid giving the name of both singleton manager and singleton instance
2015-06-18 11:31:29 +02:00
Patrik Nordwall
a0e0c394fe !clt #15110 Use buffer instead of stash in cluster client
* drop first in ClusterClient
2015-06-18 11:18:35 +02:00
Patrik Nordwall
e2608e7cc2 !clt #15110 Use buffer instead of stash in singleton proxy
* drop first in singleton proxy
2015-06-18 11:18:24 +02:00
Patrik Nordwall
6d26b3e591 !per Make persistent failures fatal
* remove PersistentFailure and RecoveryFailure messages
* use stop instead of ActorKilledException
* adjust PersistentView
* adjust AtLeastOnceDeliveryFailureSpec
* adjust sharding
* add BackoffSupervisor
2015-06-17 15:49:47 +02:00
Patrik Nordwall
5fab2b4521 !cls #16422 Rename shardResolver and idExtractor 2015-06-16 13:38:57 +02:00
Patrik Nordwall
70024298ac !cls #16422 Rename Entry to Entity in sharding 2015-06-11 10:00:43 +02:00
Patrik Nordwall
8de24f38ca !cls #17158 Add configuration of sharding journal
* Use same type of settings object as in cluster-tools
* These settings can be different for different entity types
2015-06-11 10:00:41 +02:00
Patrik Nordwall
c1d5221bf8 !clt #17364 Make ShardRegion.props internal
* the extension api is enough
* simplify how roles are specified
* make proxy mode more explicit by seperate
  method `startProxy`
2015-06-11 10:00:41 +02:00
Patrik Nordwall
1be5bb48df +cls #16050 Support graceful shutdown of ShardRegion
* possibility to define handOffStopMessage that is used
  for stopping the entries, both when graceful shutdown
  and rebalance
2015-06-02 15:04:20 +02:00
Patrik Nordwall
1dac401099 Merge pull request #17601 from akka/wip-17576-manifest-patriknw
+act #17576 Support serializer with string manifest
2015-06-01 13:46:17 +02:00
Patrik Nordwall
740f006a38 +act #17576 Support serializer with string manifest
* useful when evolution is needed, e.g. Akka Persistence

* docs, comments, cluster-metrics and cluster-tools serializers
2015-06-01 13:45:31 +02:00
Patrik Nordwall
d2a00d3b98 Merge pull request #16255 from leonidb/master
+per #15279 FSM for PersistentActor
2015-06-01 13:13:47 +02:00
Stephen Nancekivell
e4fa103577 Fix code formatting. 2015-05-31 08:52:21 +10:00
leonidb
09b6abd614 +per #15279 FSM for PersistentActor 2015-05-29 18:30:38 +03:00
Konrad Malawski
228ace497f Merge pull request #17593 from ktoso/wip-deferAsync-ktoso
!per #16797 rename defer to deferAsync, remove Seq version
2015-05-29 15:13:00 +02:00
Roland Kuhn
122fdedd08 fix typo in cluster-usage.rst 2015-05-28 21:18:48 +02:00
Konrad Malawski
d782cf59af !per #16797 rename defer to deferAsync, remove Seq version 2015-05-28 01:37:38 +02:00
Patrik Nordwall
8a7d7715b5 clu #17565 Invoke OnMemberRemoved callback when
cluster.shutdown

* must also be done when the listener actor stops before the
  MemberRemoved event has been received
* add test for this
* clarify docs with example that shuts down actor system and
  exit jvm
2015-05-27 15:42:53 +02:00
kukido
ab0c60eca7 =doc Fixed and normalized spellings 2015-05-23 19:16:41 -07:00
Patrik Nordwall
bcb36c36d9 !con #15331 Support async allocateShard and rebalance 2015-05-19 13:53:07 +02:00