Control.Funflow.External.Coordinator.SQLite

SQLLite co-ordinator for Funflow.

This co-ordinator effectively uses the shared filesystem as a tool for task distribution and sequencing. This means that it can control a distributed funflow task without needing any additional processes running.

Documentation

data SQLite

SQLite coordinator tag.

Constructors

SQLite

Instances

Coordinator SQLite

Defined in Control.Funflow.External.Coordinator.SQLite

Associated Types

type Config SQLite :: *

type Hook SQLite = (h :: *)

Methods

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

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

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

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

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

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

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

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

type Config SQLite

Defined in Control.Funflow.External.Coordinator.SQLite

type Config SQLite = Path Abs Dir

type Hook SQLite

Defined in Control.Funflow.External.Coordinator.SQLite

type Hook SQLite