Control.Eff.Concurrent.Protocol.Broker

A process broker spawns and monitors child processes.

The child processes are mapped to symbolic identifier values: Child-IDs.

This is the barest, most minimal version of a broker. Children can be started, but not restarted.

Children can efficiently be looked-up by an id-value, and when the broker is shutdown, all children will be shutdown these are actually all the features of this broker implementation.

Also, this minimalist broker only knows how to spawn a single kind of child process.

When a broker spawns a new child process, it expects the child process to return a ProcessId. The broker will monitor the child process.

This is in stark contrast to how Erlang/OTP handles things; In the OTP Supervisor, the child has to link to the parent. This allows the child spec to be more flexible in that no pid has to be passed from the child start function to the broker process, and also, a child may break free from the broker by unlinking.

Now while this seems nice at first, this might actually cause surprising results, since it is usually expected that stopping a broker also stops the children, or that a child exit shows up in the logging originating from the former broker.

The approach here is to allow any child to link to the broker to realize when the broker was violently killed, and otherwise give the child no chance to unlink itself from its broker.

This module is far simpler than the Erlang/OTP counter part, of a simple_one_for_one supervisor.

The future of this broker might not be a-lot more than it currently is. The ability to restart processes might be implemented outside of this broker module.

One way to do that is to implement the restart logic in a separate module, since the child-id can be reused when a child exits.

Since: 0.23.0

Documentation

startLink :: forall p e. (HasCallStack, IoLogging (Processes e), TangibleBroker p, Server (Broker p) (Processes e)) => StartArgument (Broker p) -> Eff (Processes e) (Endpoint (Broker p))

Start and link a new broker process with the given SpawnFununction.

To spawn new child processes use spawnChild.

Since: 0.23.0

statefulChild :: forall p e. (HasCallStack, IoLogging e, TangibleBroker (Stateful p), Server (Broker (Stateful p)) e) => Timeout -> (ChildId p -> StartArgument p) -> StartArgument (Broker (Stateful p))

A smart constructor for MkBrokerConfig that makes it easy to start a Server instance.

The user needs to instantiate ChildId p.

Since: 0.30.0

stopBroker :: (HasCallStack, HasProcesses e q, Member Logs e, Lifted IO e, TangibleBroker p) => Endpoint (Broker p) -> Eff e ()

Stop the broker and shutdown all processes.

Block until the broker has finished.

Since: 0.23.0

isBrokerAlive :: forall p q0 e. (HasCallStack, Member Logs e, Typeable p, HasProcesses e q0) => Endpoint (Broker p) -> Eff e Bool

Check if a broker process is still alive.

Since: 0.23.0

monitorBroker :: forall p q0 e. (HasCallStack, Member Logs e, HasProcesses e q0, TangibleBroker p) => Endpoint (Broker p) -> Eff e MonitorReference

Monitor a broker process.

Since: 0.23.0

getDiagnosticInfo :: forall p e q0. (HasCallStack, HasProcesses e q0, TangibleBroker p) => Endpoint (Broker p) -> Eff e Text

Return a Text describing the current state of the broker.

Since: 0.23.0

spawnChild :: forall p q0 e. (HasCallStack, Member Logs e, HasProcesses e q0, TangibleBroker p, Typeable (ServerPdu p)) => Endpoint (Broker p) -> ChildId p -> Eff e (Either (SpawnErr p) (Endpoint (ServerPdu p)))

Start and monitor a new child process using the SpawnFun passed to startLink.

Since: 0.23.0

spawnOrLookup :: forall p q0 e. (HasCallStack, Member Logs e, HasProcesses e q0, TangibleBroker p, Typeable (ServerPdu p)) => Endpoint (Broker p) -> ChildId p -> Eff e (Endpoint (ServerPdu p))

Start and monitor a new child process using the SpawnFun passed to startLink.

Call spawnChild and unpack the Either result, ignoring the AlreadyStarted error.

Since: 0.29.2

lookupChild :: forall p e q0. (HasCallStack, Member Logs e, HasProcesses e q0, TangibleBroker p, Typeable (ServerPdu p)) => Endpoint (Broker p) -> ChildId p -> Eff e (Maybe (Endpoint (ServerPdu p)))

Lookup the given child-id and return the output value of the SpawnFun if the client process exists.

Since: 0.23.0

callById :: forall destination protocol result e q0. (HasCallStack, Member Logs e, HasProcesses e q0, Lifted IO e, Lifted IO q0, TangibleBroker protocol, TangiblePdu destination (Synchronous result), TangiblePdu protocol (Synchronous result), Embeds (ServerPdu destination) protocol, Ord (ChildId destination), Tangible (ChildId destination), Typeable (ServerPdu destination), Tangible result, NFData (Pdu protocol (Synchronous result)), NFData (Pdu (ServerPdu destination) (Synchronous result)), Show (Pdu (ServerPdu destination) (Synchronous result))) => Endpoint (Broker destination) -> ChildId destination -> Pdu protocol (Synchronous result) -> Timeout -> Eff e result

castById :: forall destination protocol e q0. (HasCallStack, Member Logs e, HasProcesses e q0, TangibleBroker protocol, TangiblePdu destination Asynchronous, TangiblePdu protocol Asynchronous) => Endpoint (Broker destination) -> ChildId destination -> Pdu protocol Asynchronous -> Eff e ()

stopChild :: forall p e q0. (HasCallStack, Member Logs e, HasProcesses e q0, TangibleBroker p) => Endpoint (Broker p) -> ChildId p -> Eff e Bool

Stop a child process, and block until the child has exited.

Return True if a process with that ID was found, False if no process with the given ID was running.

Since: 0.23.0

data ChildNotFound child where

Constructors

ChildNotFound :: ChildId child -> Endpoint (Broker child) -> ChildNotFound child

Instances

(Show (ChildId child), Typeable child) => Show (ChildNotFound child)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

showsPrec :: Int -> ChildNotFound child -> ShowS

show :: ChildNotFound child -> String

showList :: [ChildNotFound child] -> ShowS

NFData (ChildId c) => NFData (ChildNotFound c)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

rnf :: ChildNotFound c -> ()

data Broker (p :: Type)

The index type of Server supervisors.

A Broker p manages the life cycle of the processes, running the Server p methods of that specific type.

The broker maps an identifier value of type ChildId p to an Endpoint p.

Since: 0.24.0

Instances

Typeable p => HasPdu (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Associated Types

type EmbeddedPduList (Broker p) :: [Type]

data Pdu (Broker p) reply :: Type

Typeable p => HasPduPrism (Broker p) (ObserverRegistry (ChildEvent p))

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

embeddedPdu :: Prism' (Pdu (Broker p) result) (Pdu (ObserverRegistry (ChildEvent p)) result)

embedPdu :: Pdu (ObserverRegistry (ChildEvent p)) result -> Pdu (Broker p) result

fromPdu :: Pdu (Broker p) result -> Maybe (Pdu (ObserverRegistry (ChildEvent p)) result)

(IoLogging q, TangibleBroker p, Tangible (ChildId p), Typeable (ServerPdu p), Server p (Processes q), HasProcesses (ServerEffects p (Processes q)) q) => Server (Broker p) (Processes q)

Defined in Control.Eff.Concurrent.Protocol.Broker

Associated Types

data StartArgument (Broker p) :: Type

type Protocol (Broker p) :: Type

data Model (Broker p) :: Type

type Settings (Broker p) :: Type

Methods

title :: StartArgument (Broker p) -> ProcessTitle

setup :: Endpoint (Protocol (Broker p)) -> StartArgument (Broker p) -> Eff (Processes q) (Model (Broker p), Settings (Broker p))

update :: Endpoint (Protocol (Broker p)) -> StartArgument (Broker p) -> Event (Protocol (Broker p)) -> Eff (ModelState (Broker p) ': (SettingsReader (Broker p) ': Processes q)) ()

(Typeable p, Show (ChildId p)) => Show (Pdu (Broker p) r)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

showsPrec :: Int -> Pdu (Broker p) r -> ShowS

show :: Pdu (Broker p) r -> String

showList :: [Pdu (Broker p) r] -> ShowS

NFData (ChildId p) => NFData (Pdu (Broker p) r)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

rnf :: Pdu (Broker p) r -> ()

type EmbeddedPduList (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

type EmbeddedPduList (Broker p) = ObserverRegistry (ChildEvent p) ': ([] :: [Type])

data Pdu (Broker p) r

Defined in Control.Eff.Concurrent.Protocol.Broker

data Pdu (Broker p) r where

• StartC :: forall p (r :: Synchronicity). ChildId p -> Pdu (Broker p) (Synchronous (Either (SpawnErr p) (Endpoint (ServerPdu p))))
• StopC :: forall p (r :: Synchronicity). ChildId p -> Timeout -> Pdu (Broker p) (Synchronous Bool)
• LookupC :: forall p (r :: Synchronicity). ChildId p -> Pdu (Broker p) (Synchronous (Maybe (Endpoint (ServerPdu p))))
• GetDiagnosticInfo :: forall p (r :: Synchronicity). Pdu (Broker p) (Synchronous Text)
• ChildEventObserverRegistry :: forall p (r :: Synchronicity). Pdu (ObserverRegistry (ChildEvent p)) r -> Pdu (Broker p) r

data StartArgument (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

data StartArgument (Broker p) = MkBrokerConfig {

• brokerConfigChildStopTimeout :: Timeout
• brokerConfigStartFun :: ChildId p -> Init p

}

type Protocol (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

type Protocol (Broker p) = Broker p

data Model (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

data Model (Broker p) = BrokerModel {

• _children :: Children (ChildId p) p
• _childEventObserver :: ObserverRegistry (ChildEvent p)

}

type Settings (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

type Settings (Broker p) = ()

type ToPretty (Broker p :: Type)

Defined in Control.Eff.Concurrent.Protocol.Broker

type ToPretty (Broker p :: Type) = "broker" <:> ToPretty p

data family Pdu protocol (reply :: Synchronicity)

The protocol data unit type for the given protocol.

Instances

(Show (Pdu a1 r), Show (Pdu a2 r)) => Show (Pdu (a1, a2) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

showsPrec :: Int -> Pdu (a1, a2) r -> ShowS

show :: Pdu (a1, a2) r -> String

showList :: [Pdu (a1, a2) r] -> ShowS

(Show (Pdu a1 r), Show (Pdu a2 r), Show (Pdu a3 r)) => Show (Pdu (a1, a2, a3) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

showsPrec :: Int -> Pdu (a1, a2, a3) r -> ShowS

show :: Pdu (a1, a2, a3) r -> String

showList :: [Pdu (a1, a2, a3) r] -> ShowS

(Show (Pdu a1 r), Show (Pdu a2 r), Show (Pdu a3 r), Show (Pdu a4 r)) => Show (Pdu (a1, a2, a3, a4) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

showsPrec :: Int -> Pdu (a1, a2, a3, a4) r -> ShowS

show :: Pdu (a1, a2, a3, a4) r -> String

showList :: [Pdu (a1, a2, a3, a4) r] -> ShowS

(Show (Pdu a1 r), Show (Pdu a2 r), Show (Pdu a3 r), Show (Pdu a4 r), Show (Pdu a5 r)) => Show (Pdu (a1, a2, a3, a4, a5) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

showsPrec :: Int -> Pdu (a1, a2, a3, a4, a5) r -> ShowS

show :: Pdu (a1, a2, a3, a4, a5) r -> String

showList :: [Pdu (a1, a2, a3, a4, a5) r] -> ShowS

Typeable event => Show (Pdu (ObserverRegistry event) r)

Defined in Control.Eff.Concurrent.Protocol.Observer

Methods

showsPrec :: Int -> Pdu (ObserverRegistry event) r -> ShowS

show :: Pdu (ObserverRegistry event) r -> String

showList :: [Pdu (ObserverRegistry event) r] -> ShowS

Show event => Show (Pdu (Observer event) r)

Defined in Control.Eff.Concurrent.Protocol.Observer

Methods

showsPrec :: Int -> Pdu (Observer event) r -> ShowS

show :: Pdu (Observer event) r -> String

showList :: [Pdu (Observer event) r] -> ShowS

(Typeable p, Show (ChildId p)) => Show (Pdu (Broker p) r)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

showsPrec :: Int -> Pdu (Broker p) r -> ShowS

show :: Pdu (Broker p) r -> String

showList :: [Pdu (Broker p) r] -> ShowS

(Show (ChildId child), Typeable child, Typeable (ServerPdu child)) => Show (Pdu (Watchdog child) r)

Defined in Control.Eff.Concurrent.Protocol.Watchdog

Methods

showsPrec :: Int -> Pdu (Watchdog child) r -> ShowS

show :: Pdu (Watchdog child) r -> String

showList :: [Pdu (Watchdog child) r] -> ShowS

(NFData (Pdu a1 r), NFData (Pdu a2 r)) => NFData (Pdu (a1, a2) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

rnf :: Pdu (a1, a2) r -> ()

(NFData (Pdu a1 r), NFData (Pdu a2 r), NFData (Pdu a3 r)) => NFData (Pdu (a1, a2, a3) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

rnf :: Pdu (a1, a2, a3) r -> ()

(NFData (Pdu a1 r), NFData (Pdu a2 r), NFData (Pdu a3 r), NFData (Pdu a4 r)) => NFData (Pdu (a1, a2, a3, a4) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

rnf :: Pdu (a1, a2, a3, a4) r -> ()

(Typeable r, NFData (Pdu a1 r), NFData (Pdu a2 r), NFData (Pdu a3 r), NFData (Pdu a4 r), NFData (Pdu a5 r)) => NFData (Pdu (a1, a2, a3, a4, a5) r)

Defined in Control.Eff.Concurrent.Protocol

Methods

rnf :: Pdu (a1, a2, a3, a4, a5) r -> ()

NFData (Pdu (ObserverRegistry event) r)

Defined in Control.Eff.Concurrent.Protocol.Observer

Methods

rnf :: Pdu (ObserverRegistry event) r -> ()

NFData event => NFData (Pdu (Observer event) r)

Defined in Control.Eff.Concurrent.Protocol.Observer

Methods

rnf :: Pdu (Observer event) r -> ()

NFData (ChildId p) => NFData (Pdu (Broker p) r)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

rnf :: Pdu (Broker p) r -> ()

NFData (ChildId child) => NFData (Pdu (Watchdog child) r)

Defined in Control.Eff.Concurrent.Protocol.Watchdog

Methods

rnf :: Pdu (Watchdog child) r -> ()

data Pdu (ObserverRegistry event) r

Defined in Control.Eff.Concurrent.Protocol.Observer

data Pdu (ObserverRegistry event) r where

• RegisterObserver :: forall event (r :: Synchronicity). Serializer (Pdu (Observer event) Asynchronous) -> ProcessId -> Pdu (ObserverRegistry event) Asynchronous
• ForgetObserver :: forall event (r :: Synchronicity). ProcessId -> Pdu (ObserverRegistry event) Asynchronous

data Pdu (Broker p) r

Defined in Control.Eff.Concurrent.Protocol.Broker

data Pdu (Broker p) r where

• StartC :: forall p (r :: Synchronicity). ChildId p -> Pdu (Broker p) (Synchronous (Either (SpawnErr p) (Endpoint (ServerPdu p))))
• StopC :: forall p (r :: Synchronicity). ChildId p -> Timeout -> Pdu (Broker p) (Synchronous Bool)
• LookupC :: forall p (r :: Synchronicity). ChildId p -> Pdu (Broker p) (Synchronous (Maybe (Endpoint (ServerPdu p))))
• GetDiagnosticInfo :: forall p (r :: Synchronicity). Pdu (Broker p) (Synchronous Text)
• ChildEventObserverRegistry :: forall p (r :: Synchronicity). Pdu (ObserverRegistry (ChildEvent p)) r -> Pdu (Broker p) r

data Pdu (Watchdog child) r

Defined in Control.Eff.Concurrent.Protocol.Watchdog

data Pdu (Watchdog child) r where

• Attach :: forall child (r :: Synchronicity). Endpoint (Broker child) -> Bool -> Pdu (Watchdog child) (Synchronous ())
• GetCrashReports :: forall child (r :: Synchronicity). Pdu (Watchdog child) (Synchronous (Map (ChildId child) (ChildWatch child)))
• OnChildEvent :: forall child (r :: Synchronicity). ChildEvent child -> Pdu (Watchdog child) Asynchronous

type ToPretty (Pdu x y :: Type)

Defined in Control.Eff.Concurrent.Protocol

type ToPretty (Pdu x y :: Type) = PrettySurrounded (PutStr "<") (PutStr ">") (("protocol" <:> ToPretty x) <+> ToPretty y)

data Pdu (a1, a2) r

Defined in Control.Eff.Concurrent.Protocol

data Pdu (a1, a2) r

• = ToPduLeft (Pdu a1 r)
• | ToPduRight (Pdu a2 r)

data Pdu (Observer event) r

Defined in Control.Eff.Concurrent.Protocol.Observer

data Pdu (Observer event) r where

• Observed :: forall event (r :: Synchronicity). event -> Pdu (Observer event) Asynchronous

data Pdu (a1, a2, a3) r

Defined in Control.Eff.Concurrent.Protocol

data Pdu (a1, a2, a3) r

• = ToPdu1 (Pdu a1 r)
• | ToPdu2 (Pdu a2 r)
• | ToPdu3 (Pdu a3 r)

data Pdu (a1, a2, a3, a4) r

Defined in Control.Eff.Concurrent.Protocol

data Pdu (a1, a2, a3, a4) r

• = ToPdu1Of4 (Pdu a1 r)
• | ToPdu2Of4 (Pdu a2 r)
• | ToPdu3Of4 (Pdu a3 r)
• | ToPdu4Of4 (Pdu a4 r)

data Pdu (a1, a2, a3, a4, a5) r

Defined in Control.Eff.Concurrent.Protocol

data Pdu (a1, a2, a3, a4, a5) r

• = ToPdu1Of5 (Pdu a1 r)
• | ToPdu2Of5 (Pdu a2 r)
• | ToPdu3Of5 (Pdu a3 r)
• | ToPdu4Of5 (Pdu a4 r)
• | ToPdu5Of5 (Pdu a5 r)

type family ChildId p

The type of value used to index running Server processes managed by a Broker.

Note, that the type you provide must be Tangible.

Since: 0.24.0

Instances

type ChildId (Stateful p)

Defined in Control.Eff.Concurrent.Protocol.Broker

type ChildId (Stateful p) = ChildId p

data family StartArgument a

The value that defines what is required to initiate a Server loop.

Instances

data StartArgument (ObservationQueue event)

Defined in Control.Eff.Concurrent.Protocol.Observer.Queue

data StartArgument (ObservationQueue event) = MkObservationQueue (ObservationQueue event)

data StartArgument (Broker p)

Defined in Control.Eff.Concurrent.Protocol.Broker

data StartArgument (Broker p) = MkBrokerConfig {

• brokerConfigChildStopTimeout :: Timeout
• brokerConfigStartFun :: ChildId p -> Init p

}

data StartArgument (Watchdog child)

Defined in Control.Eff.Concurrent.Protocol.Watchdog

data StartArgument (Watchdog child) = StartWatchDog {

• _crashRate :: CrashRate

}

brokerConfigChildStopTimeout :: StartArgument (Broker p) -> Timeout

data SpawnErr p

Runtime-Errors occurring when spawning child-processes.

Since: 0.23.0

Constructors

AlreadyStarted (ChildId p) (Endpoint (ServerPdu p))

Instances

Eq (ChildId p) => Eq (SpawnErr p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

(==) :: SpawnErr p -> SpawnErr p -> Bool

(/=) :: SpawnErr p -> SpawnErr p -> Bool

Ord (ChildId p) => Ord (SpawnErr p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

compare :: SpawnErr p -> SpawnErr p -> Ordering

(<) :: SpawnErr p -> SpawnErr p -> Bool

(<=) :: SpawnErr p -> SpawnErr p -> Bool

(>) :: SpawnErr p -> SpawnErr p -> Bool

(>=) :: SpawnErr p -> SpawnErr p -> Bool

max :: SpawnErr p -> SpawnErr p -> SpawnErr p

min :: SpawnErr p -> SpawnErr p -> SpawnErr p

(Typeable (ServerPdu p), Show (ChildId p)) => Show (SpawnErr p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

showsPrec :: Int -> SpawnErr p -> ShowS

show :: SpawnErr p -> String

showList :: [SpawnErr p] -> ShowS

Generic (SpawnErr p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Associated Types

type Rep (SpawnErr p) :: Type -> Type

Methods

from :: SpawnErr p -> Rep (SpawnErr p) x

to :: Rep (SpawnErr p) x -> SpawnErr p

NFData (ChildId p) => NFData (SpawnErr p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

rnf :: SpawnErr p -> ()

type Rep (SpawnErr p)

Defined in Control.Eff.Concurrent.Protocol.Broker

type Rep (SpawnErr p) = D1 (MetaData "SpawnErr" "Control.Eff.Concurrent.Protocol.Broker" "extensible-effects-concurrent-0.32.0-GimAdtHOovq4dulPgeQPe9" False) (C1 (MetaCons "AlreadyStarted" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ChildId p)) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Endpoint (ServerPdu p)))))

data ChildEvent p where

The event type to indicate that a child was started or stopped.

The need for this type originated for the watchdog functionality introduced in 0.30.0. The watch dog shall restart a crashed child, and in order to do so, it must somehow monitor the child. Since no order is specified in which processes get the ProcessDown events, a watchdog cannot monitor a child and restart it immediately, because it might have received the process down event before the broker. So instead the watchdog can simply use the broker events, and monitor only the broker process.

Since: 0.30.0

Constructors

OnChildSpawned :: Endpoint (Broker p) -> ChildId p -> Endpoint (ServerPdu p) -> ChildEvent p

OnChildDown :: Endpoint (Broker p) -> ChildId p -> Endpoint (ServerPdu p) -> Interrupt NoRecovery -> ChildEvent p

OnBrokerShuttingDown

Fields

• :: Endpoint (Broker p)
• -> ChildEvent p

  The broker is shutting down and will soon begin stopping/killing its children

Instances

(Typeable p, Typeable (ServerPdu p), Show (ChildId p)) => Show (ChildEvent p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

showsPrec :: Int -> ChildEvent p -> ShowS

show :: ChildEvent p -> String

showList :: [ChildEvent p] -> ShowS

Generic (ChildEvent p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Associated Types

type Rep (ChildEvent p) :: Type -> Type

Methods

from :: ChildEvent p -> Rep (ChildEvent p) x

to :: Rep (ChildEvent p) x -> ChildEvent p

NFData (ChildId p) => NFData (ChildEvent p)

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

rnf :: ChildEvent p -> ()

Typeable p => HasPduPrism (Broker p) (ObserverRegistry (ChildEvent p))

Defined in Control.Eff.Concurrent.Protocol.Broker

Methods

embeddedPdu :: Prism' (Pdu (Broker p) result) (Pdu (ObserverRegistry (ChildEvent p)) result)

embedPdu :: Pdu (ObserverRegistry (ChildEvent p)) result -> Pdu (Broker p) result

fromPdu :: Pdu (Broker p) result -> Maybe (Pdu (ObserverRegistry (ChildEvent p)) result)

Typeable child => HasPduPrism (Watchdog child) (Observer (ChildEvent child))

Defined in Control.Eff.Concurrent.Protocol.Watchdog

Methods

embeddedPdu :: Prism' (Pdu (Watchdog child) result) (Pdu (Observer (ChildEvent child)) result)

embedPdu :: Pdu (Observer (ChildEvent child)) result -> Pdu (Watchdog child) result

fromPdu :: Pdu (Watchdog child) result -> Maybe (Pdu (Observer (ChildEvent child)) result)

type Rep (ChildEvent p)

Defined in Control.Eff.Concurrent.Protocol.Broker

type Rep (ChildEvent p) = D1 (MetaData "ChildEvent" "Control.Eff.Concurrent.Protocol.Broker" "extensible-effects-concurrent-0.32.0-GimAdtHOovq4dulPgeQPe9" False) (C1 (MetaCons "OnChildSpawned" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Endpoint (Broker p))) :*: (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ChildId p)) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Endpoint (ServerPdu p))))) :+: (C1 (MetaCons "OnChildDown" PrefixI False) ((S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Endpoint (Broker p))) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ChildId p))) :*: (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Endpoint (ServerPdu p))) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Interrupt NoRecovery)))) :+: C1 (MetaCons "OnBrokerShuttingDown" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Endpoint (Broker p))))))