You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2022/10/31 09:34:51 UTC

[incubator-pekko-samples] 01/01: example of enabling Telemetry for cluster sample

This is an automated email from the ASF dual-hosted git repository.

fanningpj pushed a commit to branch wip-cinnamon-sample-patriknw
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-samples.git

commit f084f339cd9c171707fa5e32f29c7f8f48292702
Author: Patrik Nordwall <pa...@gmail.com>
AuthorDate: Wed Apr 10 15:03:40 2019 +0000

    example of enabling Telemetry for cluster sample
---
 akka-sample-cluster-scala/build.sbt                | 32 ++++++++++++++++++----
 akka-sample-cluster-scala/project/plugins.sbt      | 11 ++++++++
 .../src/main/resources/application.conf            | 23 ++++++++++++++++
 3 files changed, 60 insertions(+), 6 deletions(-)

diff --git a/akka-sample-cluster-scala/build.sbt b/akka-sample-cluster-scala/build.sbt
index fac7470..bd69908 100644
--- a/akka-sample-cluster-scala/build.sbt
+++ b/akka-sample-cluster-scala/build.sbt
@@ -5,13 +5,24 @@ val akkaVersion = "2.5.22"
 
 lazy val `akka-sample-cluster-scala` = project
   .in(file("."))
+  .enablePlugins(Cinnamon)
   .settings(multiJvmSettings: _*)
   .settings(
     organization := "com.typesafe.akka.samples",
     scalaVersion := "2.12.8",
-    scalacOptions in Compile ++= Seq("-deprecation", "-feature", "-unchecked", "-Xlog-reflective-calls", "-Xlint"),
+    scalacOptions in Compile ++= Seq(
+      "-deprecation",
+      "-feature",
+      "-unchecked",
+      "-Xlog-reflective-calls",
+      "-Xlint"
+    ),
     javacOptions in Compile ++= Seq("-Xlint:unchecked", "-Xlint:deprecation"),
-    javaOptions in run ++= Seq("-Xms128m", "-Xmx1024m", "-Djava.library.path=./target/native"),
+    javaOptions in run ++= Seq(
+      "-Xms128m",
+      "-Xmx1024m",
+      "-Djava.library.path=./target/native"
+    ),
     libraryDependencies ++= Seq(
       "com.typesafe.akka" %% "akka-actor" % akkaVersion,
       "com.typesafe.akka" %% "akka-remote" % akkaVersion,
@@ -20,11 +31,20 @@ lazy val `akka-sample-cluster-scala` = project
       "com.typesafe.akka" %% "akka-cluster-tools" % akkaVersion,
       "com.typesafe.akka" %% "akka-multi-node-testkit" % akkaVersion,
       "org.scalatest" %% "scalatest" % "3.0.7" % Test,
-      "io.kamon" % "sigar-loader" % "1.6.6-rev002"),
+      "io.kamon" % "sigar-loader" % "1.6.6-rev002",
+      Cinnamon.library.cinnamonCHMetrics,
+      Cinnamon.library.cinnamonAkka,
+    ),
     fork in run := true,
-    mainClass in (Compile, run) := Some("sample.cluster.simple.SimpleClusterApp"),
+    mainClass in (Compile, run) := Some(
+      "sample.cluster.simple.SimpleClusterApp"
+    ),
     // disable parallel tests
     parallelExecution in Test := false,
-    licenses := Seq(("CC0", url("http://creativecommons.org/publicdomain/zero/1.0")))
+    licenses := Seq(
+      ("CC0", url("http://creativecommons.org/publicdomain/zero/1.0"))
+    ),
+    cinnamon in run := true,
+    cinnamon in test := true
   )
-  .configs (MultiJvm)
+  .configs(MultiJvm)
diff --git a/akka-sample-cluster-scala/project/plugins.sbt b/akka-sample-cluster-scala/project/plugins.sbt
index 2d02635..f72eb4b 100644
--- a/akka-sample-cluster-scala/project/plugins.sbt
+++ b/akka-sample-cluster-scala/project/plugins.sbt
@@ -1,2 +1,13 @@
 addSbtPlugin("com.typesafe.sbt" % "sbt-multi-jvm" % "0.4.0")
 addSbtPlugin("com.dwijnand" % "sbt-dynver" % "3.0.0")
+
+addSbtPlugin("com.lightbend.cinnamon" % "sbt-cinnamon" % "2.11.1-SNAPSHOT")
+
+credentials += Credentials(
+  Path.userHome / ".lightbend" / "commercial.credentials"
+)
+
+resolvers += Resolver.url(
+  "lightbend-commercial",
+  url("https://repo.lightbend.com/commercial-releases")
+)(Resolver.ivyStylePatterns)
diff --git a/akka-sample-cluster-scala/src/main/resources/application.conf b/akka-sample-cluster-scala/src/main/resources/application.conf
index ba4f129..7830458 100644
--- a/akka-sample-cluster-scala/src/main/resources/application.conf
+++ b/akka-sample-cluster-scala/src/main/resources/application.conf
@@ -35,3 +35,26 @@ akka.extensions=["akka.cluster.metrics.ClusterMetricsExtension"]
 # Sigar native library extract location during tests.
 # Note: use per-jvm-instance folder when running multiple jvm on one host.
 akka.cluster.metrics.native-library-extract-folder=${user.dir}/target/native
+
+cinnamon.application = "ClusterSystem"
+
+cinnamon.akka {
+  actors {
+    "/user/*" {
+      report-by = class
+    }
+  }
+
+  cluster {
+    domain-events = on
+    member-events = on
+    split-brain-resolver-events = off
+    singleton-events = off
+    shard-region-info = off
+    node-metrics = on
+  }
+}
+cinnamon.chmetrics {
+  reporters += "console-reporter"
+}
+


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org