From b08c7ebfabbf936ced17abe5e74a88f57ce1f655 Mon Sep 17 00:00:00 2001 From: Devis Lucato Date: Tue, 24 Jan 2017 14:20:21 -0800 Subject: [PATCH 1/2] =?UTF-8?q?Fix=20metrics=20documentation=20=E2=80=9Csa?= =?UTF-8?q?mple-period=E2=80=9D=20to=20=E2=80=9Csample-interval=E2=80=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- akka-docs/rst/java/cluster-metrics.rst | 4 ++-- akka-docs/rst/scala/cluster-metrics.rst | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/akka-docs/rst/java/cluster-metrics.rst b/akka-docs/rst/java/cluster-metrics.rst index f6621d03eb..1eb88ec1c2 100644 --- a/akka-docs/rst/java/cluster-metrics.rst +++ b/akka-docs/rst/java/cluster-metrics.rst @@ -59,11 +59,11 @@ Metrics Events Metrics extension periodically publishes current snapshot of the cluster metrics to the node system event bus. -The publication period is controlled by the ``akka.cluster.metrics.collector.sample-period`` setting. +The publication interval is controlled by the ``akka.cluster.metrics.collector.sample-interval`` setting. The payload of the ``akka.cluster.metrics.ClusterMetricsChanged`` event will contain latest metrics of the node as well as other cluster member nodes metrics gossip -which was received during the collector sample period. +which was received during the collector sample interval. You can subscribe your metrics listener actors to these events in order to implement custom node lifecycle :: diff --git a/akka-docs/rst/scala/cluster-metrics.rst b/akka-docs/rst/scala/cluster-metrics.rst index 6a0f34e6ec..9d6086b59a 100644 --- a/akka-docs/rst/scala/cluster-metrics.rst +++ b/akka-docs/rst/scala/cluster-metrics.rst @@ -55,11 +55,11 @@ Metrics Events Metrics extension periodically publishes current snapshot of the cluster metrics to the node system event bus. -The publication period is controlled by the ``akka.cluster.metrics.collector.sample-period`` setting. +The publication interval is controlled by the ``akka.cluster.metrics.collector.sample-interval`` setting. The payload of the ``akka.cluster.metrics.ClusterMetricsChanged`` event will contain latest metrics of the node as well as other cluster member nodes metrics gossip -which was received during the collector sample period. +which was received during the collector sample interval. You can subscribe your metrics listener actors to these events in order to implement custom node lifecycle :: From 804392291ccf566448848ce532e709cc8ffb9295 Mon Sep 17 00:00:00 2001 From: Devis Lucato Date: Tue, 24 Jan 2017 14:20:33 -0800 Subject: [PATCH 2/2] fix typos --- akka-docs/rst/java/distributed-pub-sub.rst | 2 +- akka-docs/rst/scala/distributed-pub-sub.rst | 2 +- .../sample/cluster/stats/StatsSampleSingleMasterSpec.scala | 2 +- .../multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala | 2 +- .../multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/akka-docs/rst/java/distributed-pub-sub.rst b/akka-docs/rst/java/distributed-pub-sub.rst index a6dd858772..4a19d872fc 100644 --- a/akka-docs/rst/java/distributed-pub-sub.rst +++ b/akka-docs/rst/java/distributed-pub-sub.rst @@ -104,7 +104,7 @@ Send ---- This is a point-to-point mode where each message is delivered to one destination, -but you still does not have to know where the destination is located. +but you still do not have to know where the destination is located. A typical usage of this mode is private chat to one other user in an instant messaging application. It can also be used for distributing tasks to registered workers, like a cluster aware router where the routees dynamically can register themselves. diff --git a/akka-docs/rst/scala/distributed-pub-sub.rst b/akka-docs/rst/scala/distributed-pub-sub.rst index 18b41019e0..1296888909 100644 --- a/akka-docs/rst/scala/distributed-pub-sub.rst +++ b/akka-docs/rst/scala/distributed-pub-sub.rst @@ -107,7 +107,7 @@ Send ---- This is a point-to-point mode where each message is delivered to one destination, -but you still does not have to know where the destination is located. +but you still do not have to know where the destination is located. A typical usage of this mode is private chat to one other user in an instant messaging application. It can also be used for distributing tasks to registered workers, like a cluster aware router where the routees dynamically can register themselves. diff --git a/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala b/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala index 6e725c036f..da1b5c20f9 100644 --- a/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala +++ b/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala @@ -27,7 +27,7 @@ object StatsSampleSingleMasterSpecConfig extends MultiNodeConfig { // register the named roles (nodes) of the test val first = role("first") val second = role("second") - val third = role("thrid") + val third = role("third") def nodeList = Seq(first, second, third) diff --git a/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala b/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala index 847ccac18e..02a9f09580 100644 --- a/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala +++ b/akka-samples/akka-sample-cluster-java/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala @@ -23,7 +23,7 @@ object StatsSampleSpecConfig extends MultiNodeConfig { // register the named roles (nodes) of the test val first = role("first") val second = role("second") - val third = role("thrid") + val third = role("third") def nodeList = Seq(first, second, third) diff --git a/akka-samples/akka-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala b/akka-samples/akka-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala index 23734d0740..8b958268ea 100644 --- a/akka-samples/akka-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala +++ b/akka-samples/akka-sample-cluster-scala/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala @@ -19,7 +19,7 @@ object StatsSampleSpecConfig extends MultiNodeConfig { // register the named roles (nodes) of the test val first = role("first") val second = role("second") - val third = role("thrid") + val third = role("third") def nodeList = Seq(first, second, third)