Commit graph

14785 commits

Author SHA1 Message Date
Konrad Malawski
fa8a2e3496 Merge pull request #17852 from akka/wip-17851-ddata-experimental-patriknw
=cdd #17851 Mark distributed data as experimental
2015-06-26 15:34:58 +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
b0c2817a36 Merge pull request #17843 from akka/wip-17799-deleteMessages-refactoring-bug-patriknw
+per #17799 Fix refactoring bug in deleteMessages
2015-06-26 12:06:07 +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
Patrik Nordwall
dd13de5559 Merge pull request #17838 from akka/wip-17832-rem-SyncWriteJournal-patriknw
!per #17832 Remove SyncWriteJournal
2015-06-26 10:58:42 +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
17760c020c Merge pull request #17797 from akka/wip-17261-persistent-shard-patriknw
=cls #17261 Use persistent shard only when rememberEntities=true
2015-06-25 20:07:36 +02:00
Patrik Nordwall
f288e90d62 Merge pull request #17835 from akka/wip-17598-writerUID-patriknw
=per #17598 Add writerUuid to PersistentRepr
2015-06-25 20:06:39 +02:00
Patrik Nordwall
00449cd9ec =per #17598 Add writerUuid to PersistentRepr
* to support detection of multiple writers, facility to do
  that automatically is not part of this commit
2015-06-25 20:06:13 +02:00
Patrik Nordwall
abd430c8ce Merge pull request #17834 from akka/wip-17799-rm-permanent-patriknw
!per #17799 Remove support for non-permanent deletes
2015-06-25 19:18:45 +02:00
Konrad Malawski
8c8e6a570d Merge pull request #17818 from akka/wip-15377-persistAll-atomic-patriknw
!per #15377 Mandate atomic writes for persistAll, and support rejections
2015-06-25 18:42:11 +02:00
Patrik Nordwall
9b27abd646 =per Harden SnapshotStoreSpec
* publish to eventStream was done too early
* verify the reply message
2015-06-25 16:53:00 +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
33ee447ec9 Merge pull request #17647 from ktoso/wip-snapshot-delete-failure-ktoso
!+per snapshot store improvements, (async, errors and configurable attempts)
2015-06-25 15:07:04 +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
541ac83b10 +str #17751 configurable load attempts for local-snapshot-store 2015-06-25 10:19:55 +02:00
Konrad Malawski
63baaf1b2b !per #17586 async snapshot delete and remove timestamp from deleteSnapshot() 2015-06-25 10:19:55 +02:00
Patrik Nordwall
156204aa81 Merge pull request #17823 from akka/wip-16890-LeaderDowningNodeThatIsUnreachableSpec-patriknw
=clu #16890 Add missing barrier in LeaderDowningNodeThatIsUnreachableSpec
2015-06-24 19:28:58 +02:00
Konrad Malawski
10649ce68c Merge pull request #17632 from ktoso/wip-model-adapter-ktoso
+str #17579 #17617 EventAdapter
2015-06-24 18:09:50 +02:00
Konrad Malawski
c34914a4fe +pro #17611 add perl script to find javadoc errors 2015-06-24 16:34:36 +02:00
Patrik Nordwall
7239fd8397 =clu #16890 Add missing barrier in LeaderDowningNodeThatIsUnreachableSpec 2015-06-24 16:11:49 +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
0214d6e14d Merge pull request #17722 from ktoso/wip-port-master-tuples-ktoso
+act #17719 introduce Tuple3-22 classes for java api (master)
2015-06-23 16:56:25 +02:00
Konrad Malawski
9e3a9983a7 +act #17719 introduce Tuple3-22 classes for java api 2015-06-23 15:01:35 +02:00
Konrad Malawski
2c606383e5 Merge pull request #17763 from ktoso/wip-17690-validations-in-root-actor-path-ktoso
=act #17690 add additional validation for name param in RootActorPath
2015-06-22 17:16:53 +02:00
Roland Kuhn
97b586a278 Update CONTRIBUTING.md 2015-06-22 15:12:23 +02:00
Roland Kuhn
dc54a27755 point out akka/dev gitter channel in CONTRIBUTING 2015-06-22 15:11:37 +02:00
Patrik Nordwall
985510d6ac =cls #17261 Use persistent shard only when rememberEntities=true 2015-06-22 08:54:42 +02:00
Patrik Nordwall
d02b003628 =cls Split sharding classes into separate files 2015-06-22 08:09:10 +02:00
Roland Kuhn
37a14b98cc Merge pull request #17648 from nraychaudhuri/add_java_fsm_with_stash
Adding AbstractFSMWithStash Java API
2015-06-19 12:10:35 +02:00
Roland Kuhn
0de9f0ff40 Merge pull request #17641 from kukido/kukido-spellings-normalization
=doc #17329 Fixed and normalized spellings in ScalaDoc and comments
2015-06-19 12:06:53 +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
Patrik Nordwall
4ca20d16ac Merge pull request #17499 from akka/wip-16799-distributed-data-patriknw
+dis #16799 Add Distributed Data module
2015-06-18 18:51:45 +02:00
Patrik Nordwall
57da65fa06 Merge pull request #17646 from akka/wip-down-improvements-patriknw
=clu Improve cluster downing
2015-06-18 17:08:14 +02:00
Christopher Hunt
62f621d9ed =cdd #16799 Add another test for changed events 2015-06-18 16:53:55 +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
2a88f4fb29 =clu Improve cluster downing
* avoid using Down and Exiting member from being used for joining
* delay shut down of Down member until the information is spread
  to all reachable members, e.g. downing several nodes via one node
* akka.cluster.down-removal-margin setting
  Margin until shards or singletons that belonged to a
  downed/removed partition are created in surviving partition.
  Used by singleton and sharding.
* remove the retry count parameters/settings for singleton in
  favor of deriving those from the removal-margin
2015-06-18 12:55:54 +02:00
Patrik Nordwall
bf28260cd0 Merge pull request #17744 from akka/wip-16542-persistent-sender-patriknw
=per #16542 Don't store sender in PersistentRepr
2015-06-18 12:51:49 +02:00
Patrik Nordwall
a2e5b3f8a4 =per #16542 Don't store sender in PersistentRepr
* I think it originated from channels, or some idea that
  the sender should be revived (as good as possible) during replay,
  but that is pretty useless
* It must still be in PersistentRepr for remote serialization
* I didn't want to change to the built in sender when looping to the
  journal because keeping it together with the message makes it easier
  to do batching (queueing)
* adjust tck
2015-06-18 12:46:50 +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
450a43e5dd Merge pull request #17742 from akka/wip-15644-persist-seq-patriknw
!per #15644 Rename persist(seq) to persistAll
2015-06-18 11:35:03 +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
bc4d480d7e Merge pull request #17697 from akka/wip-15110-singleton-proxy-buffer-patriknw
!clt #15110 Use buffer instead of stash in singleton proxy and cluster client
2015-06-18 11:20:16 +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