Workflow-0.3: 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 type WorkflowStep m a = a -> Workflow m a type WorkflowList m a = [(String, WorkflowStep m a)] data Stat a 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, Typeable a) => Filter a -> a -> IO a waitUntil :: Integer -> IO () 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

type WorkflowStep m a = a -> Workflow m a Source

type WorkflowList m a = [(String, WorkflowStep m a)] Source

data Stat a Source

Instances Typeable1 Stat Serialize a => Serialize (Stat a) (IResource a, Serialize a, Typeable a) => IResource (Stat a)

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, Typeable a) => Filter a -> a -> IO a Source

waitUntil :: Integer -> IO () Source

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

Produced by Haddock version 2.4.2