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

Holumbus.MapReduce.TaskProcessor Portability portable Stability experimental Maintainer Stefan Schmidt (stefanschmidt@web.de)

Contents Datatypes Creation and Destruction TaskProcessor Info an Debug Task Creation and Destruction

Description

Version : 0.1

Synopsis

type TaskResultFunction = TaskData -> IO Bool type TaskProcessor = MVar TaskProcessorData printTaskProcessor :: TaskProcessor -> IO String newTaskProcessor :: IO TaskProcessor closeTaskProcessor :: TaskProcessor -> IO () setFileSystemToTaskProcessor :: FileSystem -> TaskProcessor -> IO () setActionMap :: KeyMap ActionData -> TaskProcessor -> IO () setTaskCompletedHook :: TaskResultFunction -> TaskProcessor -> IO () setTaskErrorHook :: TaskResultFunction -> TaskProcessor -> IO () startTaskProcessor :: TaskProcessor -> IO () stopTaskProcessor :: TaskProcessor -> IO () listTaskIds :: TaskProcessor -> IO [TaskId] getActions :: TaskProcessor -> IO [ActionData] getActionNames :: TaskProcessor -> IO [ActionName] startTask :: TaskData -> TaskProcessor -> IO () stopTask :: TaskId -> TaskProcessor -> IO () stopAllTasks :: TaskProcessor -> IO ()

Datatypes

type TaskResultFunction = TaskData -> IO Bool Source

a function for responding a

type TaskProcessor = MVar TaskProcessorData Source

printTaskProcessor :: TaskProcessor -> IO String Source

Creation and Destruction

newTaskProcessor :: IO TaskProcessor Source

creates a new TaskProcessor

closeTaskProcessor :: TaskProcessor -> IO () Source

setFileSystemToTaskProcessor :: FileSystem -> TaskProcessor -> IO () Source

add a filesystem-instance to the TaskProcessor

setActionMap :: KeyMap ActionData -> TaskProcessor -> IO () Source

adds an ActionMap to the TaskProcessor

setTaskCompletedHook :: TaskResultFunction -> TaskProcessor -> IO () Source

setTaskErrorHook :: TaskResultFunction -> TaskProcessor -> IO () Source

TaskProcessor

startTaskProcessor :: TaskProcessor -> IO () Source

stopTaskProcessor :: TaskProcessor -> IO () Source

Info an Debug

listTaskIds :: TaskProcessor -> IO [TaskId] Source

getActions :: TaskProcessor -> IO [ActionData] Source

Lists all Actions with Name, Descrition and so on

getActionNames :: TaskProcessor -> IO [ActionName] Source

Lists all Names of the Actions

Task Creation and Destruction

startTask :: TaskData -> TaskProcessor -> IO () Source

adds a Task to the TaskProcessor, the execution might be later

stopTask :: TaskId -> TaskProcessor -> IO () Source

stopAllTasks :: TaskProcessor -> IO () Source

Produced by Haddock version 2.6.1