| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Control.Concurrent.Capataz.Internal.Types.Lens
- 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 -> IO ()) -> f (CapatazEvent -> IO ())) -> CapatazOptions -> f CapatazOptions
- workerOnFailureL :: Functor f => ((SomeException -> IO ()) -> f (SomeException -> IO ())) -> WorkerOptions -> f WorkerOptions
- workerOnCompletionL :: Functor f => (IO () -> f (IO ())) -> WorkerOptions -> f WorkerOptions
- workerOnTerminationL :: Functor f => (IO () -> f (IO ())) -> WorkerOptions -> f WorkerOptions
- workerTerminationPolicyL :: Functor f => (WorkerTerminationPolicy -> f WorkerTerminationPolicy) -> WorkerOptions -> f WorkerOptions
- workerRestartStrategyL :: Functor f => (WorkerRestartStrategy -> f WorkerRestartStrategy) -> WorkerOptions -> f WorkerOptions
Documentation
class HasSupervisorIntensity s where Source #
Minimal complete definition
Methods
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 #
Minimal complete definition
Methods
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 #
Minimal complete definition
Methods
supervisorRestartStrategyL :: Functor f => (SupervisorRestartStrategy -> f SupervisorRestartStrategy) -> s -> f s Source #
Specifies the SupervisorRestartStrategy for a root supervisor.
class HasSupervisorProcessSpecList s where Source #
Minimal complete definition
Methods
supervisorProcessSpecListL :: Functor f => ([ProcessSpec] -> f [ProcessSpec]) -> s -> f s Source #
Specifies a static list of processes that start automatically with a supervisor.
class HasSupervisorProcessTerminationOrder s where Source #
Minimal complete definition
Methods
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 #
Minimal complete definition
class HasSupervisorFailureCallback s where Source #
Minimal complete definition
Methods
supervisorOnFailureL :: Functor f => ((SomeException -> IO ()) -> f (SomeException -> IO ())) -> s -> f s Source #
Specifies callback sub-routine that gets executed when a supervisor fails.
onSystemEventL :: Functor f => ((CapatazEvent -> IO ()) -> f (CapatazEvent -> IO ())) -> CapatazOptions -> f CapatazOptions Source #
workerOnFailureL :: Functor f => ((SomeException -> IO ()) -> f (SomeException -> IO ())) -> WorkerOptions -> f WorkerOptions 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 => (IO () -> f (IO ())) -> WorkerOptions -> f WorkerOptions 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 => (IO () -> f (IO ())) -> WorkerOptions -> f WorkerOptions 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 -> f WorkerOptions Source #
Specifies how to handle a worker termination. See WorkerTerminationPolicy documentation for more details.
workerRestartStrategyL :: Functor f => (WorkerRestartStrategy -> f WorkerRestartStrategy) -> WorkerOptions -> f WorkerOptions Source #
Specifies how supervisor should deal with an error when worker fails or completes. See WorkerRestartStrategy documentation for more details.