public class MetricQueryService
extends akka.actor.UntypedActor
It is realized as an actor and can be notified of
- an added metric by calling notifyOfAddedMetric(ActorRef, Metric, String, AbstractMetricGroup)
- a removed metric by calling notifyOfRemovedMetric(ActorRef, Metric)
- a metric dump request by sending the return value of getCreateDump()
Modifier and Type | Field and Description |
---|---|
static String |
METRIC_QUERY_SERVICE_NAME |
Constructor and Description |
---|
MetricQueryService(long messageSizeLimit) |
Modifier and Type | Method and Description |
---|---|
static Object |
getCreateDump() |
static void |
notifyOfAddedMetric(akka.actor.ActorRef service,
Metric metric,
String metricName,
AbstractMetricGroup group)
Utility method to notify a MetricQueryService of an added metric.
|
static void |
notifyOfRemovedMetric(akka.actor.ActorRef service,
Metric metric)
Utility method to notify a MetricQueryService of a removed metric.
|
void |
onReceive(Object message) |
void |
postStop() |
static akka.actor.ActorRef |
startMetricQueryService(akka.actor.ActorSystem actorSystem,
ResourceID resourceID,
long maximumFramesize)
Starts the MetricQueryService actor in the given actor system.
|
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
public static final String METRIC_QUERY_SERVICE_NAME
public void postStop()
postStop
in interface akka.actor.Actor
postStop
in class akka.actor.UntypedActor
public void onReceive(Object message)
onReceive
in class akka.actor.UntypedActor
public static akka.actor.ActorRef startMetricQueryService(akka.actor.ActorSystem actorSystem, ResourceID resourceID, long maximumFramesize)
actorSystem
- The actor system running the MetricQueryServiceresourceID
- resource ID to disambiguate the actor namepublic static void notifyOfAddedMetric(akka.actor.ActorRef service, Metric metric, String metricName, AbstractMetricGroup group)
service
- MetricQueryService to notifymetric
- added metricmetricName
- metric namegroup
- group the metric was added onpublic static void notifyOfRemovedMetric(akka.actor.ActorRef service, Metric metric)
service
- MetricQueryService to notifymetric
- removed metricpublic static Object getCreateDump()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.