Holumbus-MapReduce-0.1.0: a distributed MapReduce framework Source code Contents Index

Holumbus.Distribution.Messages Portability portable Stability experimental Maintainer Stefan Schmidt (stefanschmidt@web.de)

Contents Datatypes Messages to and from the Master Messages to and from the Worker request an response handling

Description

Version : 0.1

Synopsis

type WorkerId = Int data MasterRequestMessage = MReqTaskCompleted TaskData | MReqTaskError TaskData | MReqStartControlling | MReqStopControlling | MReqIsControlling | MReqSingleStep | MReqPerformJob JobInfo | MReqUnknown data MasterResponseMessage = MRspSuccess | MRspIsControlling Bool | MRspResult JobResult | MRspError String | MRspUnknown data WorkerRequestMessage = WReqStartTask TaskData | WReqStopTask TaskId | WReqStopAllTasks | WReqGetActionNames | WReqUnknown data WorkerResponseMessage = WRspSuccess | WRspGetActionNames [ActionName] | WRspError String | WRspUnknown performPortAction :: (Show a, Binary a, Show b, Binary b, RspMsg b) => Port a -> Stream b -> Int -> a -> (b -> IO (Maybe c)) -> IO c

Datatypes

type WorkerId = Int Source

Messages to and from the Master

data MasterRequestMessage Source

Constructors MReqTaskCompleted TaskData MReqTaskError TaskData MReqStartControlling MReqStopControlling MReqIsControlling MReqSingleStep MReqPerformJob JobInfo MReqUnknown Instances Show MasterRequestMessage Binary MasterRequestMessage

data MasterResponseMessage Source

Constructors MRspSuccess MRspIsControlling Bool MRspResult JobResult MRspError String MRspUnknown Instances Show MasterResponseMessage RspMsg MasterResponseMessage Binary MasterResponseMessage

Messages to and from the Worker

data WorkerRequestMessage Source

Constructors WReqStartTask TaskData WReqStopTask TaskId WReqStopAllTasks WReqGetActionNames WReqUnknown Instances Show WorkerRequestMessage Binary WorkerRequestMessage

data WorkerResponseMessage Source

Constructors WRspSuccess WRspGetActionNames [ActionName] WRspError String WRspUnknown Instances Show WorkerResponseMessage RspMsg WorkerResponseMessage Binary WorkerResponseMessage

request an response handling

performPortAction Source

:: (Show a, Binary a, Show b, Binary b, RspMsg b) => Port a request port -> Stream b response Stream -> Int timeout for the response in mikroseconds (1000000 = 1 sec) (0 = wait for ever) -> a request message -> b -> IO (Maybe c) response handler -> IO c Sends a request to the server (stream) and handles the response and all error cases. Very helpful when simulating a request response scheme with the mailboxes.

Produced by Haddock version 2.6.1