Network.Distributed.Process

Documentation

runRequestNode

Arguments

:: Int

Number of slave nodes the master should wait for

-> NetworkConfig

-> IO ()

Runs a Process that is a master Node

runRequestNode' :: NetProc ()

Internal for master Node

joinNetwork :: NetworkConfig -> IO ()

Creates the Backend and runs a Process that is a slave Node

joinNetwork' :: Process ()

Internal for slave Node

findPids :: (MonadMask m, MonadProcess m, MonadReader AppConfig m) => m [ProcessId]

Internal function used to gather ProcessId's

gatherDeps :: (MonadProcess m, MonadMask m) => Network -> m [ProcessDeps]

Internal function used to get all slaves dependencies

receiveF :: MonadProcess m => ReceivePort Transfer -> m ()

Internal function used to reveive the Transfer

withTransfer

Arguments

:: (Exception e, MonadProcess m, MonadCatch m)

=> [ProcessDeps]

Slaves process dependencies

-> Deps

Masters dependencies

-> (e -> m ())

Recovery function

-> (ProcessId -> (SendPort Transfer, ReceivePort Transfer) -> m ())

Action to execute with the linked process and typed-channel

-> m ()

Faciliaties a safe Transfer bewteen nodes