Control.Distributed.Process.Management.Internal.Table

Documentation

data MxTableRequest

Constructors

Delete

Purge

Clear !String

Set !String !Message

Get !String !(SendPort (Maybe Message))

Instances

Generic MxTableRequest

Associated Types

type Rep MxTableRequest :: * -> *

Methods

from :: MxTableRequest -> Rep MxTableRequest x

to :: Rep MxTableRequest x -> MxTableRequest

Binary MxTableRequest

Methods

put :: MxTableRequest -> Put

get :: Get MxTableRequest

putList :: [MxTableRequest] -> Put

type Rep MxTableRequest

type Rep MxTableRequest = D1 (MetaData "MxTableRequest" "Control.Distributed.Process.Management.Internal.Table" "distributed-process-0.6.4-8Gt9w6cQP4kIZ624dikZRH" False) ((:+:) ((:+:) (C1 (MetaCons "Delete" PrefixI False) U1) (C1 (MetaCons "Purge" PrefixI False) U1)) ((:+:) (C1 (MetaCons "Clear" PrefixI False) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 String))) ((:+:) (C1 (MetaCons "Set" PrefixI False) ((:*:) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 String)) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Message)))) (C1 (MetaCons "Get" PrefixI False) ((:*:) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 String)) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (SendPort (Maybe Message)))))))))

data MxTableId

Constructors

MxForAgent !MxAgentId

MxForPid !ProcessId

Instances

Generic MxTableId

Associated Types

type Rep MxTableId :: * -> *

Methods

from :: MxTableId -> Rep MxTableId x

to :: Rep MxTableId x -> MxTableId

Binary MxTableId

Methods

put :: MxTableId -> Put

get :: Get MxTableId

putList :: [MxTableId] -> Put

type Rep MxTableId

type Rep MxTableId = D1 (MetaData "MxTableId" "Control.Distributed.Process.Management.Internal.Types" "distributed-process-0.6.4-8Gt9w6cQP4kIZ624dikZRH" False) ((:+:) (C1 (MetaCons "MxForAgent" PrefixI False) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 MxAgentId))) (C1 (MetaCons "MxForPid" PrefixI False) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ProcessId))))

mxTableCoordinator :: String

startTableCoordinator :: Fork -> Process ()

delete :: MxTableId -> Process ()

purge :: MxTableId -> Process ()

clear :: String -> MxTableId -> Process ()

set :: String -> Message -> MxTableId -> Process ()

get :: forall a. Serializable a => ProcessId -> String -> Process (Maybe a)

fetch :: forall a. Serializable a => MxTableId -> String -> Process (Maybe a)