Commit graph

911 commits

Author SHA1 Message Date
Philip L. McMahon
19195dbded Correct typo in "Backpressure aware stages" section (#22252) 2017-02-02 16:16:48 -07:00
Nafer Sanabria
432b53c509 clarify Akka Http starting version 2017-01-29 08:31:29 -07:00
Johan Andrén
52a20f2ba9 Micro kernel module removed #22205 2017-01-26 15:40:54 +01:00
Patrik Nordwall
5ffb08cd78 Merge pull request #22227 from akka/wip-sharding-dependency-patriknw
fix sharding dependency to persistence
2017-01-25 21:46:52 +01:00
Patrik Nordwall
a8f340508b fix sharding dependency to persistence
* can't make the dependency provided or test and still be able
  to compile/run tests
* might not be a big deal to include the persistence dependency instead
2017-01-25 21:45:08 +01:00
Patrik Nordwall
53a010eabc Merge pull request #22219 from akka/wip-rolling-patriknw
rolling update considerations in migration guide
2017-01-25 18:05:23 +01:00
Patrik Nordwall
b876b3e757 Merge pull request #22214 from dluc/master
Fix metrics documentation + some typos
2017-01-25 15:40:35 +01:00
Patrik Nordwall
4224ec587b rolling update considerations in migration guide 2017-01-25 15:09:46 +01:00
Patrik Nordwall
9fabbdf710 Merge pull request #22209 from akka/wip-22141-majority-patriknw
use minCap for majority write/read in sharding, #22141
2017-01-25 14:30:26 +01:00
Patrik Nordwall
233464f153 Merge pull request #22212 from akka/wip-22169-addser-default-patriknw
Enable additional-serialization-bindings by default, #22169
2017-01-25 14:29:53 +01:00
Devis Lucato
804392291c fix typos 2017-01-24 14:20:33 -08:00
Devis Lucato
b08c7ebfab Fix metrics documentation “sample-period” to “sample-interval” 2017-01-24 14:20:21 -08:00
Patrik Nordwall
9df49be5d0 Enable additional-serialization-bindings by default, #22169
* and thereby it was also possibe to simplify the documentation
  in remoting
2017-01-24 18:52:49 +01:00
Patrik Nordwall
9616e997fc Use ddata mode as the default for Cluster Sharding, #17963 2017-01-24 18:49:01 +01:00
Patrik Nordwall
b45a254685 use minCap for majority write/read in sharding, #22141
* also added some docs about the feature since that was missing
2017-01-24 16:41:18 +01:00
Patrik Nordwall
0c1d9e3d2e Merge pull request #22202 from akka/wip-22201-promote-ddata-patriknw
Promote Distributed Data, #22201
2017-01-24 16:34:31 +01:00
Patrik Nordwall
554d119446 Merge pull request #22200 from akka/wip-21190-promote-PersistenceFSM-patriknw
Promote PersistenceFSM, #21190
2017-01-24 14:38:48 +01:00
Patrik Nordwall
261a04714e Merge pull request #22204 from akka/wip-22197-promote-WeaklyUp-patriknw
Promote WeaklyUp and enable by default, #22197
2017-01-24 14:38:13 +01:00
Patrik Nordwall
3e7ffd6b96 Add support for delta-CRDT, #21875
* delta GCounter and PNCounter
* first stab at delta propagation protocol
* send delta in the direct write
* possibility to turn off delta propagation
* tests
* protobuf serializer for DeltaPropagation
* documentation
2017-01-24 13:24:45 +01:00
Patrik Nordwall
f409c06c78 Promote Distributed Data, #22201 2017-01-24 12:49:27 +01:00
Patrik Nordwall
1700cdaebc Promote WeaklyUp and enable by default, #22197 2017-01-24 12:31:32 +01:00
Patrik Nordwall
99be3cb7b5 Promote PersistenceFSM, #21190 2017-01-24 11:21:37 +01:00
Patrik Nordwall
e7144eef02 rename lambda doc files, #21717 2017-01-23 18:30:52 +01:00
Patrik Nordwall
4bd6b7aab1 improve AbstractActor, #21717
* Receive class that wraps PartialFunction, to avoid
  scary scala types
* move AbstractActorContext to AbstractActor.ActorContext
* converting docs, many, many UntypedActor
* removing UntypedActor docs
* add unit test for ReceiveBuilder
* MiMa filters
* consistent use of getContext(), self(), sender()
* rename cross references
* migration guide
* skip samples for now
* improve match type safetyi, add matchUnchecked
  * the `? extends P` caused code like this to compile:
    `match(String.class, (Integer i) -> {})`
  * added matchUnchecked, since it can still be useful (um, convenient)
    to be able to do:
    `matchUnchecked(List.class, (List<String> list) -> {})`
* eleminate some scala.Option
  * preRestart
  * findChild
  * ActorIdentity.getActorRef
2017-01-23 18:30:52 +01:00
Patrik Nordwall
952be31a7d make pruning of CRDT garbage work, #21647
* fix merge issues of DataEnvelope and its pruning
* simplify by removing the tombstones, which didn't work in all cases anyway
* keep the PruningPerformed markers in the DataEnvelope until configured
  TTL has elapsed (wall clock)
* simplify PruningState structure
* also store the pruning markers in durable data
* collect removed nodes from the data, listing on MemberRemoved is not enough
* possibility to disable pruning altogether
* documented caveat for durable data
2017-01-23 16:54:02 +01:00
Patrik Nordwall
37679d307e rememberingEntities with ddata mode, #22154
* one Replicator per configured role
* log LMDB directory at startup
* clarify the imporantce of the LMDB directory
* use more than one key to support many entities
2017-01-23 11:57:52 +01:00
Patrik Nordwall
5de92866ee Merge pull request #22172 from akka/wip-samples-coordinated-patriknw
Don't shutdown ActorSystem in tests
2017-01-20 13:58:25 +01:00
Patrik Nordwall
452b3f1406 remove old deprecated cluster metrics, #21423
* corresponding was moved to akka-cluster-metrics, see
  http://doc.akka.io/docs/akka/2.4/project/migration-guide-2.3.x-2.4.x.html#New_Cluster_Metrics_Extension
2017-01-20 13:48:36 +01:00
Patrik Nordwall
4722252bf1 cleanup old migration guides (#22164) 2017-01-20 13:33:23 +01:00
Patrik Nordwall
611dc93261 add note about CoordinatedShutdown and tests, #21537 2017-01-20 13:25:29 +01:00
Patrik Nordwall
c61ed5a240 Merge pull request #22146 from akka/wip-22145-exclusive-Sequence-patriknw
use exclusive fromSequenceNumber in eventsByTag, #22145
2017-01-17 17:48:35 +01:00
Patrik Nordwall
8083c0bf4a use exclusive fromSequenceNumber in eventsByTag, #22145
* The reason is to have a consistent approach for Sequence and
  TimeBasedUUID, which are both intended as unique event identifiers.
* This means that you can use the offset that is returned in `EventEnvelope`
  as the `offset` parameter in a subsequent query.
2017-01-16 11:43:47 +01:00
Patrik Nordwall
84ade6fdc3 add CoordinatedShutdown, #21537
* CoordinatedShutdown that can run tasks for configured phases in order (DAG)
* coordinate handover/shutdown of singleton with cluster exiting/shutdown
* phase config obj with depends-on list
* integrate graceful leaving of sharding in coordinated shutdown
* add timeout and recover
* add some missing artery ports to tests
* leave via CoordinatedShutdown.run
* optionally exit-jvm in last phase
* run via jvm shutdown hook
* send ExitingConfirmed to leader before shutdown of Exiting
  to not have to wait for failure detector to mark it as
  unreachable before removing
* the unreachable signal is still kept as a safe guard if
  message is lost or leader dies
* PhaseClusterExiting vs MemberExited in ClusterSingletonManager
* terminate ActorSystem when cluster shutdown (via Down)
* add more predefined and custom phases
* reference documentation
* migration guide
* problem when the leader order was sys2, sys1, sys3,
  then sys3 could not perform it's duties and move Leving sys1 to
  Exiting because it was observing sys1 as unreachable
* exclude Leaving with exitingConfirmed from convergence condidtion
2017-01-16 09:01:57 +01:00
Patrik Nordwall
a8f9ad4775 Merge branch 'master' into 21648-Prefer_reachable_nodes_in_consistency-jgordijn 2017-01-13 10:21:09 +01:00
Jeroen Gordijn
8499ff6faf #22035 Make it possible to use anything as the key in a map
- All Map types are now generic in their key: ORMap, ORMultiMap, LWWMap,
  PNCounterMap
- test for binary compatibility with previous version for serialization
- entries are sorted for deterministic SHA-1 on same value
2017-01-11 21:20:39 +01:00
Jeroen Gordijn
81f081b33c #21648 Prefer reachable nodes in consistency writes/reads 2017-01-09 20:36:54 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
Konrad `ktoso` Malawski
067b569f85 Merge branch 'master' into wip-query-2.5 2017-01-03 17:04:48 +01:00
Patrik Nordwall
7646506af0 Merge pull request #22020 from akka/wip-catch-deserialization-patriknw
catch NotSerializableException from deserialization, #20641
2017-01-02 16:00:06 +01:00
Patrik Nordwall
e494ec2183 catch NotSerializableException from deserialization, #20641
* to be able to introduce new messages and still support rolling upgrades,
  i.e. a cluster of mixed versions
* note that it's only catching NotSerializableException, which we already
  use for unknown serializer ids and class manifests
* note that it is not catching for system messages, since that could result
  in infinite resending
2016-12-16 20:14:37 +01:00
Patrik Nordwall
798a673e97 Merge pull request #22000 from akka/wip-19822-persistence-conf-path-patriknw
optionally pass plugin conf path to persistence plugins, #19822
2016-12-16 17:50:58 +01:00
Konrad Malawski
b036b555e4 =peq remove bridge from old APIs in PersistenceQuery 2016-12-15 13:00:26 +01:00
Konrad Malawski
2ab8ab2840 =21423 remove deprecated PersistentView 2016-12-15 12:31:20 +01:00
Konrad Malawski
926e97e930 =peq mark persistence query as stable 2016-12-14 14:09:11 +01:00
Konrad Malawski
abaa8f394e =peq #21724 #19174 unify naming of query methods 2016-12-14 14:07:56 +01:00
Konrad Malawski
e7e1f74427 =str more specific error type if idle-timeout triggers in tcp 2016-12-14 12:39:24 +01:00
Patrik Nordwall
57e59c8496 optionally pass plugin conf path to persistence plugins, #19822 2016-12-13 19:37:03 +01:00
Patrik Nordwall
db95b7ff96 add http api for cluster management, #21172
* reference akka/akka-cluster-management in cluster docs
* deprecate the command line tool, including migration note
* cleanup old migration guides
* remove YourKit as sponsor, since we pay license
2016-12-13 10:54:41 +01:00
Oleg Poleshuk
c50ecf3287 +doc Documented how CompletionStages execute #20513 (#21845)
* Documented how CompletionStages execute #20513

* Fixed the failing test: tests are not necessarily run from "main" thread.

* Addressed pull request comment #20513

* Addressed more PR comments #20513
2016-12-12 21:46:37 +01:00
Konrad `ktoso` Malawski
2ea8cd7410 =str deprecate ActorPublisher/Subscriber, use GraphStage (#21952)
* =str deprecate ActorPublisher/Subscriber, use GraphStage

* =str deprecate Source.actorPublisher / Sink.actorSubscriber

* =str added deprecation note of ActorPublisher,Subscriber
2016-12-08 17:22:01 +01:00