MetricNotifier

A metric notifier manages subscriptions from various clients and generates a Stream of Chunk[MetricState] at regular time intervals. This stream can be used to push data towards push based back-ends such as StatsD or the ZMX developers client.

Companion
object
class Object
trait Matchable
class Any

Value members

Abstract methods

def connect(): UIO[(String, UStream[MetricsUpdate], UStream[Seq[MetricKey]])]

Create a new connection generating a new id. All subscriptions within that connection will report their changes to the same stream. Secondly we create a Stream where we publish the currently discovered metricKeys on a regular basis.

Create a new connection generating a new id. All subscriptions within that connection will report their changes to the same stream. Secondly we create a Stream where we publish the currently discovered metricKeys on a regular basis.

def disconnect(id: String): UIO[Unit]
def stop(): UIO[Unit]
def subscribe(conId: String, subId: String, keys: Chunk[MetricKey], interval: Duration): UIO[Unit]

Create a new subscription within a formerly created connection

Create a new subscription within a formerly created connection

def unsubscribe(conId: String, id: String): UIO[Unit]