task-distribution-0.1.0.3: Distributed processing of changing tasks

Safe HaskellNone
LanguageHaskell2010

Control.Distributed.Task.Distribution.TaskDistribution

Description

Contains all node communication (using Cloud Haskell). This includes distribution logic.

Synopsis

Documentation

startSlaveNode :: NodeConfig -> IO () Source

Start a slave listening on given hostname, port.

executeDistributed :: NodeConfig -> TaskDef -> [DataDef] -> ResultDef -> ([TaskResult] -> IO ()) -> IO () Source

Run a calculation on all accessible slaves. This is a low-level method, look at the RunComputaiton module for a nicer interface.

showSlaveNodes :: NodeConfig -> IO () Source

List all accessible slaves.

showSlaveNodesWithData :: NodeConfig -> String -> IO () Source

List all accessible slaves that have at least a single block of the specified path stored physically.

shutdownSlaveNodes :: NodeConfig -> IO () Source

Convenience method to stop all accessible slaves remotely.