Control.Funflow.External.Coordinator.Memory

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

Documentation

data MemoryCoordinator

Constructors

MemoryCoordinator

Instances

Coordinator MemoryCoordinator

Defined in Control.Funflow.External.Coordinator.Memory

Associated Types

type Config MemoryCoordinator :: *

type Hook MemoryCoordinator = (h :: *)

Methods

initialise :: MonadIO m => Config MemoryCoordinator -> m (Hook MemoryCoordinator)

submitTask :: MonadIO m => Hook MemoryCoordinator -> TaskDescription -> m ()

queueSize :: MonadIO m => Hook MemoryCoordinator -> m Int

taskInfo :: MonadIO m => Hook MemoryCoordinator -> ContentHash -> m TaskInfo

popTask :: MonadIO m => Hook MemoryCoordinator -> Executor -> m (Maybe TaskDescription)

awaitTask :: MonadIO m => Hook MemoryCoordinator -> ContentHash -> m TaskInfo

updateTaskStatus :: MonadIO m => Hook MemoryCoordinator -> ContentHash -> TaskStatus -> m ()

dropTasks :: MonadIO m => Hook MemoryCoordinator -> m ()

type Config MemoryCoordinator

Defined in Control.Funflow.External.Coordinator.Memory

type Config MemoryCoordinator = MemHook

type Hook MemoryCoordinator

Defined in Control.Funflow.External.Coordinator.Memory

type Hook MemoryCoordinator = MemHook

data MemHook

Constructors

MemHook

Fields

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

mhTaskQueue :: Lens' MemHook (TVar [TaskDescription])

mhExecutionQueue :: Lens' MemHook (TVar (Map ContentHash TaskStatus))

createMemoryCoordinator :: IO MemHook