Workflow-0.1: library for transparent execution of computations across shutdowns and restarts Source code Contents Index

Control.Workflow

Synopsis

type Workflow m l = WF m (Stat l) l step :: (Workflow_ a, Monad m) => (a -> m a) -> a -> Workflow m a startWF :: (Workflow_ a, Monad m) => String -> a -> WorkflowList m a -> m a restartWorkflows :: (Workflow_ a, IResource a, Serialize a) => WorkflowList IO a -> IO () getStep :: Monad m => Int -> Workflow m a getAll :: Monad m => WF m (Stat a) [a] unsafeIOtoWF waitFor :: (IResource a, Serialize a) => Filter a -> a -> IO a syncWrite :: (Workflow_ a, Monad m, IResource a) => Bool -> Int -> Int -> WF m (Stat a) ()

Documentation

type Workflow m l = WF m (Stat l) l Source

step :: (Workflow_ a, Monad m) => (a -> m a) -> a -> Workflow m a Source

step lift a monadic computation (a -> m a) in in to the WF monad, provides state loging and automatic resume

startWF :: (Workflow_ a, Monad m) => String -> a -> WorkflowList m a -> m a Source

start or continue a workflow. WorkflowList is a assoclist of (name, workflow computation)

restartWorkflows :: (Workflow_ a, IResource a, Serialize a) => WorkflowList IO a -> IO () Source

getStep :: Monad m => Int -> Workflow m a Source

getAll :: Monad m => WF m (Stat a) [a] Source

unsafeIOtoWF

waitFor :: (IResource a, Serialize a) => Filter a -> a -> IO a Source

syncWrite :: (Workflow_ a, Monad m, IResource a) => Bool -> Int -> Int -> WF m (Stat a) () Source

Produced by Haddock version 2.4.2