Control.Funflow.External.Coordinator.Redis

Redis-based co-ordinator for Funflow.

There are two co-ordinators defined in this module. They differ in whether they open a new connection to Redis or re-use an existing one. Other than that they behave identically.

Documentation

data Redis

Constructors

Redis

Instances

Coordinator Redis

Defined in Control.Funflow.External.Coordinator.Redis

Associated Types

type Config Redis :: Type

type Hook Redis = (h :: Type)

Methods

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

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

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

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

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

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

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

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

type Config Redis

Defined in Control.Funflow.External.Coordinator.Redis

type Config Redis = ConnectInfo

type Hook Redis

Defined in Control.Funflow.External.Coordinator.Redis

type Hook Redis = Connection

data RedisPreconnected

Constructors

RedisPreconnected

Instances

Coordinator RedisPreconnected

Allow a preestablished redis connection to be used.

Defined in Control.Funflow.External.Coordinator.Redis

Associated Types

type Config RedisPreconnected :: Type

type Hook RedisPreconnected = (h :: Type)

Methods

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

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

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

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

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

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

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

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

type Config RedisPreconnected

Defined in Control.Funflow.External.Coordinator.Redis

type Config RedisPreconnected = Connection

type Hook RedisPreconnected

Defined in Control.Funflow.External.Coordinator.Redis

type Hook RedisPreconnected