{-# options_haddock prune #-}
module Polysemy.Conc.Effect.Monitor where
import Polysemy.Time (NanoSeconds)
import Polysemy.Conc.Effect.Scoped (Scoped_, scoped_)
data Restart =
Restart
deriving stock (Restart -> Restart -> Bool
(Restart -> Restart -> Bool)
-> (Restart -> Restart -> Bool) -> Eq Restart
forall a. (a -> a -> Bool) -> (a -> a -> Bool) -> Eq a
/= :: Restart -> Restart -> Bool
$c/= :: Restart -> Restart -> Bool
== :: Restart -> Restart -> Bool
$c== :: Restart -> Restart -> Bool
Eq, Int -> Restart -> ShowS
[Restart] -> ShowS
Restart -> String
(Int -> Restart -> ShowS)
-> (Restart -> String) -> ([Restart] -> ShowS) -> Show Restart
forall a.
(Int -> a -> ShowS) -> (a -> String) -> ([a] -> ShowS) -> Show a
showList :: [Restart] -> ShowS
$cshowList :: [Restart] -> ShowS
show :: Restart -> String
$cshow :: Restart -> String
showsPrec :: Int -> Restart -> ShowS
$cshowsPrec :: Int -> Restart -> ShowS
Show)
data Monitor (action :: Type) :: Effect where
Monitor :: m a -> Monitor action m a
makeSem_ ''Monitor
monitor ::
∀ action r a .
Member (Monitor action) r =>
Sem r a ->
Sem r a
type ScopedMonitor (action :: Type) =
Scoped_ (Monitor action)
type RestartingMonitor =
ScopedMonitor Restart
data MonitorCheck r =
MonitorCheck {
forall (r :: [(* -> *) -> * -> *]). MonitorCheck r -> NanoSeconds
interval :: NanoSeconds,
forall (r :: [(* -> *) -> * -> *]).
MonitorCheck r -> MVar () -> Sem r ()
check :: MVar () -> Sem r ()
}
withMonitor ::
∀ action r .
Member (ScopedMonitor action) r =>
InterpreterFor (Monitor action) r
withMonitor :: forall action (r :: [(* -> *) -> * -> *]).
Member (ScopedMonitor action) r =>
InterpreterFor (Monitor action) r
withMonitor =
Sem (Monitor action : r) a -> Sem r a
forall (effect :: (* -> *) -> * -> *) (r :: [(* -> *) -> * -> *]).
Member (Scoped_ effect) r =>
InterpreterFor effect r
scoped_
restart ::
Member (ScopedMonitor Restart) r =>
InterpreterFor (Monitor Restart) r
restart :: forall (r :: [(* -> *) -> * -> *]).
Member (ScopedMonitor Restart) r =>
InterpreterFor (Monitor Restart) r
restart =
Sem (Monitor Restart : r) a -> Sem r a
forall action (r :: [(* -> *) -> * -> *]).
Member (ScopedMonitor action) r =>
InterpreterFor (Monitor action) r
withMonitor