Control.Workflow.Stat

Documentation

data WF s m l

Constructors

WF

Fields

st :: s -> m (s, l)

Instances

(Monad m, Functor m) => Functor (Workflow m)

(Monad m, Functor m) => Applicative (Workflow m)

(Monad m, MonadIO m, Serialize a, Typeable a) => PMonadTrans (WF Stat) m a

plift= step

Monad m => Monad (WF s m)

MonadIO m => MonadIO (WF Stat m)

(HasFork io, MonadIO io, MonadCatch io) => HasFork (WF Stat io)

data Stat

Constructors

Running (Map String (String, Maybe ThreadId))

Stat

Fields

self :: DBRef Stat

wfName :: String

state :: Int

recover :: Bool

timeout :: Maybe Integer

lastActive :: Integer

context :: (Context, ByteString)

references :: [(Int, (IDynamic, Bool))]

versions :: [IDynamic]

Instances

Typeable Stat

Serialize Stat

IResource Stat

(Monad m, Functor m) => Functor (Workflow m)

(Monad m, Functor m) => Applicative (Workflow m)

(Monad m, MonadIO m, Serialize a, Typeable a) => PMonadTrans (WF Stat) m a

plift= step

MonadIO m => MonadIO (WF Stat m)

(HasFork io, MonadIO io, MonadCatch io) => HasFork (WF Stat io)

stat0 :: Stat

statPrefix1 :: [Char]

statPrefix :: [Char]

header :: Stat -> STW ()

getHeader :: STR ([Char], Int, Maybe Integer, Integer, [a], (Context, ByteString))

lenLen :: Int64

keyWF :: Indexable a => String -> a -> String

Return the unique name of a workflow with a parameter (executed with exec or start)

data WFRef a

Constructors

WFRef !Int !(DBRef Stat)

Instances

Typeable1 WFRef

Read (WFRef a)

Show (WFRef a)

Serialize (WFRef a)

Indexable (WFRef a)

pathWFlows :: [Char]

stFName :: IResource a => a -> [Char]

fr :: Key -> IO (Maybe ByteString)

safe :: FilePath -> (Handle -> IO a) -> IO a

hReadFile :: Handle -> IO ByteString

readHeader :: ByteString -> Handle -> IO (Maybe ([Char], Int, Maybe Integer, Integer, [a], (Context, ByteString)))

keyRunning :: String

showHistory :: Stat -> ByteString

show the state changes along the workflow, that is, all the intermediate results

showp1 :: IDynamic -> STW ()

wFRefStr :: [Char]