Safe Haskell	None
Language	Haskell2010

Control.Funflow.External.Coordinator.Memory

Description

In-memory co-ordinator for funflow. This module is not greatly useful except for testing purposes.

Documentation

Constructors

Instances

Coordinator MemoryCoordinator Source #
Instance details Defined in Control.Funflow.External.Coordinator.Memory Associated Types type Config MemoryCoordinator :: Type Source # type Hook MemoryCoordinator = (h :: Type) Source # Methods initialise :: MonadIO m => Config MemoryCoordinator -> m (Hook MemoryCoordinator) Source # submitTask :: MonadIO m => Hook MemoryCoordinator -> TaskDescription -> m () Source # queueSize :: MonadIO m => Hook MemoryCoordinator -> m Int Source # taskInfo :: MonadIO m => Hook MemoryCoordinator -> ContentHash -> m TaskInfo Source # popTask :: MonadIO m => Hook MemoryCoordinator -> Executor -> m (Maybe TaskDescription) Source # awaitTask :: MonadIO m => Hook MemoryCoordinator -> ContentHash -> m TaskInfo Source # updateTaskStatus :: MonadIO m => Hook MemoryCoordinator -> ContentHash -> TaskStatus -> m () Source # dropTasks :: MonadIO m => Hook MemoryCoordinator -> m () Source #
type Config MemoryCoordinator Source #
Instance details Defined in Control.Funflow.External.Coordinator.Memory type Config MemoryCoordinator = MemHook
type Hook MemoryCoordinator Source #
Instance details Defined in Control.Funflow.External.Coordinator.Memory type Hook MemoryCoordinator = MemHook

Constructors

MemHook
Fields _mhTaskQueue :: TVar [TaskDescription] _mhExecutionQueue :: TVar (Map ContentHash TaskStatus)