public class ClusterMetricsStrategy extends OneForOneStrategy
ClusterMetricsSupervisor
strategy:
A configurable OneForOneStrategy
with restart-on-throwable decider.SupervisorStrategy.Directive, SupervisorStrategy.Escalate$, SupervisorStrategy.Restart$, SupervisorStrategy.Resume$, SupervisorStrategy.Stop$
Constructor and Description |
---|
ClusterMetricsStrategy(com.typesafe.config.Config config) |
Modifier and Type | Method and Description |
---|---|
static boolean |
canEqual(java.lang.Object x$1) |
static OneForOneStrategy |
copy(int maxNrOfRetries,
scala.concurrent.duration.Duration withinTimeRange,
boolean loggingEnabled,
scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider) |
static int |
copy$default$1() |
static scala.concurrent.duration.Duration |
copy$default$2() |
static boolean |
copy$default$3() |
static scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> |
decider() |
static boolean |
equals(java.lang.Object x$1) |
static void |
handleChildTerminated(ActorContext context,
ActorRef child,
scala.collection.Iterable<ActorRef> children) |
static boolean |
handleFailure(ActorContext context,
ActorRef child,
java.lang.Throwable cause,
ChildRestartStats stats,
scala.collection.Iterable<ChildRestartStats> children) |
static int |
hashCode() |
static void |
logFailure(ActorContext context,
ActorRef child,
java.lang.Throwable cause,
SupervisorStrategy.Directive decision) |
static boolean |
loggingEnabled() |
static int |
maxNrOfRetries() |
static scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> |
metricsDecider()
SupervisorStrategy Decider which allows to survive intermittent Sigar native method calls failures. |
static void |
processFailure(ActorContext context,
boolean restart,
ActorRef child,
java.lang.Throwable cause,
ChildRestartStats stats,
scala.collection.Iterable<ChildRestartStats> children) |
static int |
productArity() |
static java.lang.Object |
productElement(int x$1) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
static void |
restartChild(ActorRef child,
java.lang.Throwable cause,
boolean suspendFirst) |
static void |
resumeChild(ActorRef child,
java.lang.Throwable cause) |
static java.lang.String |
toString() |
static scala.concurrent.duration.Duration |
withinTimeRange() |
decider, handleChildTerminated, loggingEnabled, maxNrOfRetries, processFailure, withinTimeRange
defaultDecider, defaultStrategy, escalate, escalateDefault, handleFailure, logFailure, makeDecider, makeDecider, makeDecider, makeDecider, maxNrOfRetriesOption, restart, restartChild, resume, resumeChild, seqThrowable2Decider, sort, stop, stoppingStrategy, withinTimeRangeOption
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ClusterMetricsStrategy(com.typesafe.config.Config config)
public static scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> metricsDecider()
SupervisorStrategy
Decider
which allows to survive intermittent Sigar native method calls failures.public static boolean handleFailure(ActorContext context, ActorRef child, java.lang.Throwable cause, ChildRestartStats stats, scala.collection.Iterable<ChildRestartStats> children)
public static void logFailure(ActorContext context, ActorRef child, java.lang.Throwable cause, SupervisorStrategy.Directive decision)
public static final void resumeChild(ActorRef child, java.lang.Throwable cause)
public static final void restartChild(ActorRef child, java.lang.Throwable cause, boolean suspendFirst)
public static int maxNrOfRetries()
public static scala.concurrent.duration.Duration withinTimeRange()
public static boolean loggingEnabled()
public static scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider()
public static void handleChildTerminated(ActorContext context, ActorRef child, scala.collection.Iterable<ActorRef> children)
public static void processFailure(ActorContext context, boolean restart, ActorRef child, java.lang.Throwable cause, ChildRestartStats stats, scala.collection.Iterable<ChildRestartStats> children)
public static OneForOneStrategy copy(int maxNrOfRetries, scala.concurrent.duration.Duration withinTimeRange, boolean loggingEnabled, scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
public static int copy$default$1()
public static scala.concurrent.duration.Duration copy$default$2()
public static boolean copy$default$3()
public static java.lang.String productPrefix()
public static int productArity()
public static java.lang.Object productElement(int x$1)
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static boolean canEqual(java.lang.Object x$1)
public static int hashCode()
public static java.lang.String toString()
public static boolean equals(java.lang.Object x$1)