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 n m e a. (m ~> n) -> Hotqueue m e a -> Hotqueue n e a

#workLoop Source

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

#hotqueue Source

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

#hotqueueJson Source

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

Modules: Database.Redis.Hotqueue