Module

Database.Redis.Hotqueue

Package
purescript-redis-hotqueue
Repository
paluh/purescript-redis-hotqueue

#Key Source

type Key = String

#Hotqueue Source

type Hotqueue m e a = { bGet :: m (Either e a), clear :: m Unit, get :: m (Maybe (Either e a)), key :: String, put :: a -> m Unit, snapshot :: m (Array (Either e a)) }

#hoist Source

hoist :: forall a e m n. (m ~> n) -> Hotqueue m e a -> Hotqueue n e a

#workLoop Source

workLoop :: forall a e m. MonadRec m => Hotqueue m e a -> (Either e a -> m Unit) -> m Unit

#hotqueue Source

hotqueue :: forall a e eff m. MonadAff (redis :: REDIS | eff) m => Connection -> Key -> { prs :: String -> m (Either e a), ser :: a -> String } -> Hotqueue m e a

#hotqueueJson Source

hotqueueJson :: forall a eff m. MonadAff (redis :: REDIS | eff) m => WriteForeign a => ReadForeign a => Connection -> Key -> Hotqueue m MultipleErrors a