| Copyright | (c) 2018 Sean McGroarty |
|---|---|
| License | BSD3 |
| Maintainer | Sean McGroarty <[email protected]> |
| Stability | experimental |
| Safe Haskell | None |
| Language | Haskell2010 |
Network.Distributed.Process
Description
- runRequestNode :: Int -> NetworkConfig -> IO ()
- runRequestNode' :: NetProc ()
- joinNetwork :: NetworkConfig -> IO ()
- joinNetwork' :: Process ()
- findPids :: (MonadMask m, MonadProcess m, MonadReader AppConfig m) => m [ProcessId]
- gatherDeps :: (MonadProcess m, MonadMask m) => Network -> m [ProcessDeps]
- receiveF :: MonadProcess m => ReceivePort Transfer -> m ()
- withTransfer :: (Exception e, MonadProcess m, MonadCatch m) => [ProcessDeps] -> Deps -> (e -> m ()) -> (ProcessId -> (SendPort Transfer, ReceivePort Transfer) -> m ()) -> m ()
Documentation
Arguments
| :: Int | Number of slave nodes the master should wait for |
| -> NetworkConfig | |
| -> IO () |
runRequestNode' :: NetProc () Source #
Internal for master Node
joinNetwork :: NetworkConfig -> IO () Source #
joinNetwork' :: Process () Source #
Internal for slave Node
findPids :: (MonadMask m, MonadProcess m, MonadReader AppConfig m) => m [ProcessId] Source #
Internal function used to gather ProcessId's
gatherDeps :: (MonadProcess m, MonadMask m) => Network -> m [ProcessDeps] Source #
Internal function used to get all slaves dependencies
receiveF :: MonadProcess m => ReceivePort Transfer -> m () Source #
Internal function used to reveive the Transfer
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