Safe Haskell	None
Language	Haskell2010

Control.Distributed.Process.Management.Internal.Types

Synopsis

newtype MxAgentId = MxAgentId {
- agentId :: String
}
data MxAgentState s = MxAgentState {
- mxAgentId :: !MxAgentId
- mxBus :: !(TChan Message)
- mxLocalState :: !s
}
newtype MxAgent s a = MxAgent {
- unAgent :: StateT (MxAgentState s) Process a
}
data MxAction
- = MxAgentDeactivate !String
- | MxAgentPrioritise !ChannelSelector
- | MxAgentReady
- | MxAgentSkip
data ChannelSelector
- = InputChan
- | Mailbox
type Fork = Process () -> IO ProcessId
type MxSink s = Message -> MxAgent s (Maybe MxAction)
data MxEvent
class Addressable a where
- resolveToPid :: a -> Maybe ProcessId

Documentation

newtype MxAgentId Source #

A newtype wrapper for an agent id (which is a string).

Constructors

MxAgentId
Fields agentId :: String

Instances

Instances details

Binary MxAgentId Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods put :: MxAgentId -> Put # get :: Get MxAgentId # putList :: [MxAgentId] -> Put #
Eq MxAgentId Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods (==) :: MxAgentId -> MxAgentId -> Bool # (/=) :: MxAgentId -> MxAgentId -> Bool #
Ord MxAgentId Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods compare :: MxAgentId -> MxAgentId -> Ordering # (<) :: MxAgentId -> MxAgentId -> Bool # (<=) :: MxAgentId -> MxAgentId -> Bool # (>) :: MxAgentId -> MxAgentId -> Bool # (>=) :: MxAgentId -> MxAgentId -> Bool # max :: MxAgentId -> MxAgentId -> MxAgentId # min :: MxAgentId -> MxAgentId -> MxAgentId #

data MxAgentState s Source #

Constructors

MxAgentState
Fields mxAgentId :: !MxAgentId mxBus :: !(TChan Message) mxLocalState :: !s

Instances

Instances details

MonadState (MxAgentState s) (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods get :: MxAgent s (MxAgentState s) # put :: MxAgentState s -> MxAgent s () # state :: (MxAgentState s -> (a, MxAgentState s)) -> MxAgent s a #

newtype MxAgent s a Source #

Monad for management agents.

Constructors

MxAgent
Fields unAgent :: StateT (MxAgentState s) Process a

Instances

Instances details

MonadFix (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods mfix :: (a -> MxAgent s a) -> MxAgent s a #
MonadIO (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods liftIO :: IO a -> MxAgent s a #
Applicative (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods pure :: a -> MxAgent s a # (<>) :: MxAgent s (a -> b) -> MxAgent s a -> MxAgent s b # liftA2 :: (a -> b -> c) -> MxAgent s a -> MxAgent s b -> MxAgent s c # (>) :: MxAgent s a -> MxAgent s b -> MxAgent s b # (<*) :: MxAgent s a -> MxAgent s b -> MxAgent s a #
Functor (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods fmap :: (a -> b) -> MxAgent s a -> MxAgent s b # (<$) :: a -> MxAgent s b -> MxAgent s a #
Monad (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods (>>=) :: MxAgent s a -> (a -> MxAgent s b) -> MxAgent s b # (>>) :: MxAgent s a -> MxAgent s b -> MxAgent s b # return :: a -> MxAgent s a #
MonadState (MxAgentState s) (MxAgent s) Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods get :: MxAgent s (MxAgentState s) # put :: MxAgentState s -> MxAgent s () # state :: (MxAgentState s -> (a, MxAgentState s)) -> MxAgent s a #

data MxAction Source #

Represents the actions a management agent can take when evaluating an event sink.

Constructors

MxAgentDeactivate !String
MxAgentPrioritise !ChannelSelector
MxAgentReady
MxAgentSkip

data ChannelSelector Source #

Constructors

InputChan
Mailbox

type Fork = Process () -> IO ProcessId Source #

Gross though it is, this synonym represents a function used to forking new processes, which has to be passed as a HOF when calling mxAgentController, since there's no other way to avoid a circular dependency with Node.hs

type MxSink s = Message -> MxAgent s (Maybe MxAction) Source #

Type of a management agent's event sink.

data MxEvent Source #

This is the default management event, fired for various internal events around the NT connection and Process lifecycle. All published events that conform to this type, are eligible for tracing - i.e., they will be delivered to the trace controller.

Constructors

MxSpawned ProcessId	fired whenever a local process is spawned
MxRegistered ProcessId String	fired whenever a process/name is registered (locally)
MxUnRegistered ProcessId String	fired whenever a process/name is unregistered (locally)
MxProcessDied ProcessId DiedReason	fired whenever a process dies
MxNodeDied NodeId DiedReason	fired whenever a node dies (i.e., the connection is broken/disconnected)
MxSent ProcessId ProcessId Message	fired whenever a message is sent from a local process
MxSentToName String ProcessId Message	fired whenever a named send occurs
MxSentToPort ProcessId SendPortId Message	fired whenever a sendChan occurs
MxReceived ProcessId Message	fired whenever a message is received by a local process
MxReceivedPort SendPortId Message	fired whenever a message is received via a typed channel
MxConnected ConnectionId EndPointAddress	fired when a network-transport connection is first established
MxDisconnected ConnectionId EndPointAddress	fired when a network-transport connection is broken/disconnected
MxUser Message	a user defined trace event
MxLog String	a logging event - used for debugging purposes only
MxTraceTakeover ProcessId	notifies a trace listener that all subsequent traces will be sent to pid
MxTraceDisable	notifies a trace listener that it has been disabled/removed

Instances

Instances details

Generic MxEvent Source #

Instance details

Defined in Control.Distributed.Process.Management.Internal.Types

Associated Types

type Rep MxEvent

Instance details

Defined in Control.Distributed.Process.Management.Internal.Types

Methods

from :: MxEvent -> Rep MxEvent x #

to :: Rep MxEvent x -> MxEvent #

Show MxEvent Source #

Instance details

Defined in Control.Distributed.Process.Management.Internal.Types

Methods

showsPrec :: Int -> MxEvent -> ShowS #

show :: MxEvent -> String #

showList :: [MxEvent] -> ShowS #

Binary MxEvent Source #

Instance details

Defined in Control.Distributed.Process.Management.Internal.Types

Methods

put :: MxEvent -> Put #

get :: Get MxEvent #

putList :: [MxEvent] -> Put #

Addressable MxEvent Source #

Instance details

Defined in Control.Distributed.Process.Management.Internal.Types

Methods

resolveToPid :: MxEvent -> Maybe ProcessId Source #

type Rep MxEvent Source #

Instance details

Defined in Control.Distributed.Process.Management.Internal.Types

class Addressable a where Source #

The class of things that we might be able to resolve to a ProcessId (or not).

Methods

resolveToPid :: a -> Maybe ProcessId Source #

Instances

Instances details

Addressable MxEvent Source #
Instance details Defined in Control.Distributed.Process.Management.Internal.Types Methods resolveToPid :: MxEvent -> Maybe ProcessId Source #