Engine.Worker

Documentation

data Versioned a

Constructors

Versioned

Fields

• vVersion :: Vector Word64
• vData :: a

Instances

Functor Versioned

Defined in Engine.Worker

Methods

fmap :: (a -> b) -> Versioned a -> Versioned b

(<$) :: a -> Versioned b -> Versioned a

Foldable Versioned

Defined in Engine.Worker

Methods

fold :: Monoid m => Versioned m -> m

foldMap :: Monoid m => (a -> m) -> Versioned a -> m

foldMap' :: Monoid m => (a -> m) -> Versioned a -> m

foldr :: (a -> b -> b) -> b -> Versioned a -> b

foldr' :: (a -> b -> b) -> b -> Versioned a -> b

foldl :: (b -> a -> b) -> b -> Versioned a -> b

foldl' :: (b -> a -> b) -> b -> Versioned a -> b

foldr1 :: (a -> a -> a) -> Versioned a -> a

foldl1 :: (a -> a -> a) -> Versioned a -> a

toList :: Versioned a -> [a]

null :: Versioned a -> Bool

length :: Versioned a -> Int

elem :: Eq a => a -> Versioned a -> Bool

maximum :: Ord a => Versioned a -> a

minimum :: Ord a => Versioned a -> a

sum :: Num a => Versioned a -> a

product :: Num a => Versioned a -> a

Traversable Versioned

Defined in Engine.Worker

Methods

traverse :: Applicative f => (a -> f b) -> Versioned a -> f (Versioned b)

sequenceA :: Applicative f => Versioned (f a) -> f (Versioned a)

mapM :: Monad m => (a -> m b) -> Versioned a -> m (Versioned b)

sequence :: Monad m => Versioned (m a) -> m (Versioned a)

Eq (Versioned a)

Defined in Engine.Worker

Methods

(==) :: Versioned a -> Versioned a -> Bool

(/=) :: Versioned a -> Versioned a -> Bool

Ord (Versioned a)

Defined in Engine.Worker

Methods

compare :: Versioned a -> Versioned a -> Ordering

(<) :: Versioned a -> Versioned a -> Bool

(<=) :: Versioned a -> Versioned a -> Bool

(>) :: Versioned a -> Versioned a -> Bool

(>=) :: Versioned a -> Versioned a -> Bool

max :: Versioned a -> Versioned a -> Versioned a

min :: Versioned a -> Versioned a -> Versioned a

Show a => Show (Versioned a)

Defined in Engine.Worker

Methods

showsPrec :: Int -> Versioned a -> ShowS

show :: Versioned a -> String

showList :: [Versioned a] -> ShowS

HasOutput (TVar (Versioned a))

Defined in Engine.Worker

Associated Types

type GetOutput (TVar (Versioned a))

Methods

getOutput :: TVar (Versioned a) -> Var (GetOutput (TVar (Versioned a)))

HasInput (TVar (Versioned a))

Defined in Engine.Worker

Associated Types

type GetInput (TVar (Versioned a))

Methods

getInput :: TVar (Versioned a) -> Var (GetInput (TVar (Versioned a)))

type GetOutput (TVar (Versioned a))

Defined in Engine.Worker

type GetOutput (TVar (Versioned a)) = a

type GetInput (TVar (Versioned a))

Defined in Engine.Worker

type GetInput (TVar (Versioned a)) = a

type Var a = TVar (Versioned a)

newVar :: MonadUnliftIO m => a -> m (Var a)

readVar :: MonadUnliftIO m => Var a -> m a

stateVar :: HasInput var => var -> StateVar (GetInput var)

stateVarMap :: HasInput var => (GetInput var -> a) -> (a -> GetInput var -> GetInput var) -> var -> StateVar a

class HasInput a where

Associated Types

type GetInput a

Methods

getInput :: a -> Var (GetInput a)

Instances

HasInput (TVar (Versioned a))

Defined in Engine.Worker

Associated Types

type GetInput (TVar (Versioned a))

Methods

getInput :: TVar (Versioned a) -> Var (GetInput (TVar (Versioned a)))

HasInput (Cell i o)

Defined in Engine.Worker

Associated Types

type GetInput (Cell i o)

Methods

getInput :: Cell i o -> Var (GetInput (Cell i o))

pushInput :: (MonadIO m, HasInput var) => var -> (GetInput var -> GetInput var) -> m ()

pushInputSTM :: HasInput var => var -> (GetInput var -> GetInput var) -> STM ()

updateInput :: (MonadIO m, HasInput var) => var -> (GetInput var -> Maybe (GetInput var)) -> m ()

updateInputSTM :: HasInput var => var -> (GetInput var -> Maybe (GetInput var)) -> STM ()

getInputData :: (HasInput worker, MonadIO m) => worker -> m (GetInput worker)

getInputDataSTM :: HasInput worker => worker -> STM (GetInput worker)

class HasConfig a where

Associated Types

type GetConfig a

Methods

getConfig :: a -> TVar (GetConfig a)

Instances

HasConfig (TVar a)

Defined in Engine.Worker

Associated Types

type GetConfig (TVar a)

Methods

getConfig :: TVar a -> TVar (GetConfig (TVar a))

HasConfig (Timed config output)

Defined in Engine.Worker

Associated Types

type GetConfig (Timed config output)

Methods

getConfig :: Timed config output -> TVar (GetConfig (Timed config output))

modifyConfig :: (MonadIO m, HasConfig var) => var -> (GetConfig var -> GetConfig var) -> m ()

modifyConfigSTM :: HasConfig var => var -> (GetConfig var -> GetConfig var) -> STM ()

class HasOutput a where

Associated Types

type GetOutput a

Methods

getOutput :: a -> Var (GetOutput a)

Instances

HasOutput (TVar (Versioned a))

Defined in Engine.Worker

Associated Types

type GetOutput (TVar (Versioned a))

Methods

getOutput :: TVar (Versioned a) -> Var (GetOutput (TVar (Versioned a)))

HasOutput (Merge o)

Defined in Engine.Worker

Associated Types

type GetOutput (Merge o)

Methods

getOutput :: Merge o -> Var (GetOutput (Merge o))

HasOutput (Timed config output)

Defined in Engine.Worker

Associated Types

type GetOutput (Timed config output)

Methods

getOutput :: Timed config output -> Var (GetOutput (Timed config output))

HasOutput (Cell i o)

Defined in Engine.Worker

Associated Types

type GetOutput (Cell i o)

Methods

getOutput :: Cell i o -> Var (GetOutput (Cell i o))

pushOutput :: (MonadIO m, HasOutput var) => var -> (GetOutput var -> GetOutput var) -> m ()

pushOutputSTM :: HasOutput var => var -> (GetOutput var -> GetOutput var) -> STM ()

updateOutput :: (MonadIO m, HasOutput var) => var -> (GetOutput var -> Maybe (GetOutput var)) -> m ()

updateOutputSTM :: HasOutput var => var -> (GetOutput var -> Maybe (GetOutput var)) -> STM ()

getOutputData :: (HasOutput worker, MonadIO m) => worker -> m (GetOutput worker)

getOutputDataSTM :: HasOutput worker => worker -> STM (GetOutput worker)

data Cell input output

Updatable cell for composite input or costly output.

Constructors

Cell

Fields

• cWorker :: ThreadId
• cInput :: Var input
• cOutput :: Var output

Instances

HasWorker (Cell i o)

Defined in Engine.Worker

Methods

getWorker :: Cell i o -> ThreadId

HasOutput (Cell i o)

Defined in Engine.Worker

Associated Types

type GetOutput (Cell i o)

Methods

getOutput :: Cell i o -> Var (GetOutput (Cell i o))

HasInput (Cell i o)

Defined in Engine.Worker

Associated Types

type GetInput (Cell i o)

Methods

getInput :: Cell i o -> Var (GetInput (Cell i o))

type GetOutput (Cell i o)

Defined in Engine.Worker

type GetOutput (Cell i o) = o

type GetInput (Cell i o)

Defined in Engine.Worker

type GetInput (Cell i o) = i

spawnCell :: MonadUnliftIO m => (input -> output) -> input -> m (Cell input output)

data Timed config output

Timer-driven stateful producer.

Constructors

Timed

Fields

• tWorker :: ThreadId
• tActive :: TVar Bool
• tConfig :: TVar config
• tOutput :: Var output

Instances

HasWorker (Timed c o)

Defined in Engine.Worker

Methods

getWorker :: Timed c o -> ThreadId

HasOutput (Timed config output)

Defined in Engine.Worker

Associated Types

type GetOutput (Timed config output)

Methods

getOutput :: Timed config output -> Var (GetOutput (Timed config output))

HasConfig (Timed config output)

Defined in Engine.Worker

Associated Types

type GetConfig (Timed config output)

Methods

getConfig :: Timed config output -> TVar (GetConfig (Timed config output))

type GetOutput (Timed config output)

Defined in Engine.Worker

type GetOutput (Timed config output) = output

type GetConfig (Timed config output)

Defined in Engine.Worker

type GetConfig (Timed config output) = config

spawnTimed :: MonadUnliftIO m => Bool -> Either Int (config -> Int) -> (config -> m (output, state)) -> (state -> config -> m (Maybe output, state)) -> config -> m (Timed config output)

spawnTimed_ :: MonadUnliftIO m => Bool -> Int -> output -> m output -> m (Timed () output)

data Merge o

Supply-driven step cell.

Constructors

Merge

Fields

• mWorker :: ThreadId
• mOutput :: TVar (Versioned o)

Instances

HasWorker (Merge o)

Defined in Engine.Worker

Methods

getWorker :: Merge o -> ThreadId

HasOutput (Merge o)

Defined in Engine.Worker

Associated Types

type GetOutput (Merge o)

Methods

getOutput :: Merge o -> Var (GetOutput (Merge o))

type GetOutput (Merge o)

Defined in Engine.Worker

type GetOutput (Merge o) = o

spawnMerge1 :: (MonadUnliftIO m, HasOutput i) => (GetOutput i -> o) -> i -> m (Merge o)

spawnMerge2 :: (MonadUnliftIO m, HasOutput i1, HasOutput i2) => (GetOutput i1 -> GetOutput i2 -> o) -> i1 -> i2 -> m (Merge o)

spawnMerge3 :: (MonadUnliftIO m, HasOutput i1, HasOutput i2, HasOutput i3) => (GetOutput i1 -> GetOutput i2 -> GetOutput i3 -> o) -> i1 -> i2 -> i3 -> m (Merge o)

spawnMerge4 :: (MonadUnliftIO m, HasOutput i1, HasOutput i2, HasOutput i3, HasOutput i4) => (GetOutput i1 -> GetOutput i2 -> GetOutput i3 -> GetOutput i4 -> o) -> i1 -> i2 -> i3 -> i4 -> m (Merge o)

spawnMergeT :: (Traversable t, HasOutput input, MonadUnliftIO m) => (t (GetOutput input) -> output) -> t input -> m (Merge output)

Spawn a merge over a homogeneous traversable collection of processes.

A merging function will receive a collection of outputs to summarize.

type ObserverIO a = IORef (Versioned a)

newObserverIO :: MonadIO m => a -> m (ObserverIO a)

observeIO :: (MonadUnliftIO m, HasOutput output) => output -> ObserverIO a -> (a -> GetOutput output -> m a) -> m a

observeIO_ :: (MonadUnliftIO m, HasOutput output) => output -> ObserverIO a -> (a -> GetOutput output -> m a) -> m ()

readObservedIO :: MonadUnliftIO m => IORef (Versioned a) -> m a

data Source a

newSource :: (MonadUnliftIO m, UnagiPrim a) => m (Source a)

pubSource :: (MonadUnliftIO m, UnagiPrim a) => Source a -> a -> m ()

subSource :: MonadUnliftIO m => Source a -> m (OutChan a)

class HasWorker a where

Methods

getWorker :: a -> ThreadId

Instances

HasWorker (Merge o)

Defined in Engine.Worker

Methods

getWorker :: Merge o -> ThreadId

HasWorker (Timed c o)

Defined in Engine.Worker

Methods

getWorker :: Timed c o -> ThreadId

HasWorker (Cell i o)

Defined in Engine.Worker

Methods

getWorker :: Cell i o -> ThreadId

register :: (MonadResource m, HasWorker process) => process -> m ReleaseKey

registerCollection :: (MonadResource m, HasWorker process, Foldable t) => t process -> m ReleaseKey

registered :: (MonadResource m, HasWorker a) => m a -> m (ReleaseKey, a)

registeredCollection :: (MonadResource m, HasWorker process, Traversable t) => (input -> m process) -> t input -> m (ReleaseKey, t process)