| Portability | portable |
|---|---|
| Stability | experimental |
| Maintainer | Stefan Schmidt (stefanschmidt@web.de) |
Holumbus.MapReduce.TaskProcessor
Contents
Description
Version : 0.1
- 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 BoolSource
a function for responding a
type TaskProcessor = MVar TaskProcessorDataSource
Creation and Destruction
newTaskProcessor :: IO TaskProcessorSource
creates a new TaskProcessor
setFileSystemToTaskProcessor :: FileSystem -> TaskProcessor -> IO ()Source
add a filesystem-instance to the TaskProcessor
setActionMap :: KeyMap ActionData -> TaskProcessor -> IO ()Source
adds an ActionMap to the TaskProcessor
TaskProcessor
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
stopAllTasks :: TaskProcessor -> IO ()Source