Safe Haskell | None |
---|---|
Language | Haskell2010 |
- class HasSupervisorIntensity s where
- class HasSupervisorPeriodSeconds s where
- class HasSupervisorRestartStrategy s where
- class HasSupervisorProcessSpecList s where
- class HasSupervisorProcessTerminationOrder s where
- class HasSupervisorIntensityReachedCallback s where
- class HasSupervisorFailureCallback s where
- onSystemEventL :: Functor f => ((CapatazEvent -> m ()) -> f (CapatazEvent -> m ())) -> CapatazOptions m -> f (CapatazOptions m)
- workerOnFailureL :: Functor f => ((SomeException -> m ()) -> f (SomeException -> m ())) -> WorkerOptions m -> f (WorkerOptions m)
- workerOnCompletionL :: Functor f => (m () -> f (m ())) -> WorkerOptions m -> f (WorkerOptions m)
- workerOnTerminationL :: Functor f => (m () -> f (m ())) -> WorkerOptions m -> f (WorkerOptions m)
- workerTerminationPolicyL :: Functor f => (WorkerTerminationPolicy -> f WorkerTerminationPolicy) -> WorkerOptions m -> f (WorkerOptions m)
- workerRestartStrategyL :: Functor f => (WorkerRestartStrategy -> f WorkerRestartStrategy) -> WorkerOptions m -> f (WorkerOptions m)
Documentation
class HasSupervisorIntensity s where Source #
supervisorIntensityL :: Functor f => (Int -> f Int) -> s -> f s Source #
Specifies how many errors is a supervisor able to handle; check: http://erlang.org/doc/design_principles/sup_princ.html#max_intensity.
class HasSupervisorPeriodSeconds s where Source #
supervisorPeriodSecondsL :: Functor f => (NominalDiffTime -> f NominalDiffTime) -> s -> f s Source #
Specifies period of time in which a supervisor can receive a number of errors specified in "supervisorIntensityL".
class HasSupervisorRestartStrategy s where Source #
supervisorRestartStrategyL :: Functor f => (SupervisorRestartStrategy -> f SupervisorRestartStrategy) -> s -> f s Source #
Specifies the SupervisorRestartStrategy for a root supervisor.
class HasSupervisorProcessSpecList s where Source #
supervisorProcessSpecListL :: Functor f => ([ProcessSpec m] -> f [ProcessSpec m]) -> s m -> f (s m) Source #
Specifies a static list of processes that start automatically with a supervisor.
class HasSupervisorProcessTerminationOrder s where Source #
supervisorProcessTerminationOrderL :: Functor f => (ProcessTerminationOrder -> f ProcessTerminationOrder) -> s -> f s Source #
Specifies order in which a supervisor is going to terminate its supervised processes.
class HasSupervisorIntensityReachedCallback s where Source #
supervisorOnIntensityReachedL :: Functor f => (m () -> f (m ())) -> s m -> f (s m) Source #
Specifies a callback sub-routine that gets executed when there is a breach in a supervisor's error intensity.
class HasSupervisorFailureCallback s where Source #
supervisorOnFailureL :: Functor f => ((SomeException -> m ()) -> f (SomeException -> m ())) -> s m -> f (s m) Source #
Specifies callback sub-routine that gets executed when a supervisor fails.
onSystemEventL :: Functor f => ((CapatazEvent -> m ()) -> f (CapatazEvent -> m ())) -> CapatazOptions m -> f (CapatazOptions m) Source #
workerOnFailureL :: Functor f => ((SomeException -> m ()) -> f (SomeException -> m ())) -> WorkerOptions m -> f (WorkerOptions m) Source #
Specifies callback that gets executed when worker sub-routine has runtime error.
NOTE: the given sub-routine execution may be interrupted depending on the worker WorkerTerminationPolicy.
workerOnCompletionL :: Functor f => (m () -> f (m ())) -> WorkerOptions m -> f (WorkerOptions m) Source #
Specifies callback that gets executed when worker sub-routine completes with no errors.
NOTE: the given sub-routine execution may be interrupted depending on the worker WorkerTerminationPolicy.
workerOnTerminationL :: Functor f => (m () -> f (m ())) -> WorkerOptions m -> f (WorkerOptions m) Source #
Specifies callback that gets executed when worker sub-routine is terminated by its supervisor; this may happen in case of a capataz system shutdown or when there is an AllForOne restart policy in place.
NOTE: the given sub-routine execution may be interrupted depending on the worker WorkerTerminationPolicy.
workerTerminationPolicyL :: Functor f => (WorkerTerminationPolicy -> f WorkerTerminationPolicy) -> WorkerOptions m -> f (WorkerOptions m) Source #
Specifies how to handle a worker termination. See WorkerTerminationPolicy documentation for more details.
workerRestartStrategyL :: Functor f => (WorkerRestartStrategy -> f WorkerRestartStrategy) -> WorkerOptions m -> f (WorkerOptions m) Source #
Specifies how supervisor should deal with an error when worker fails or completes. See WorkerRestartStrategy documentation for more details.