Keenser.Types

Documentation

data Config m

Constructors

Config

Fields

• kWorkers :: Map WorkerName (Worker m Value)
• kQueues :: [Queue]
• kConcurrency :: Int
• kRedis :: Connection
• kMiddleware :: [Middleware m]

type Configurator m = StateT (Config m) m ()

data Job a

Constructors

Job

Fields

• jobClass :: WorkerName
• jobArgs :: a
• jobId :: JobId
• jobRetry :: Bool
• jobEnqueuedAt :: UTCTime
• jobQueue :: Queue

Instances

Functor Job

Methods

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

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

ToJSON a => ToJSON (Job a)

Methods

toJSON :: Job a -> Value

toEncoding :: Job a -> Encoding

FromJSON a => FromJSON (Job a)

Methods

parseJSON :: Value -> Parser (Job a)

type JobId = ByteString

data Manager

Constructors

Manager

Fields

• managerHostname :: ByteString
• managerStartedAt :: UTCTime
• managerPid :: Int32
• managerConcurrency :: Int
• managerQueues :: [Queue]
• managerLabels :: [Text]
• managerIdentity :: ByteString
• managerRedis :: Connection
• managerRunning :: TVar (Map ThreadId RunningJob)
• managerComplete :: TVar Integer
• managerFailed :: TVar Integer
• managerQuiet :: TVar Bool

Instances

ToJSON Manager

Methods

toJSON :: Manager -> Value

toEncoding :: Manager -> Encoding

data ManagerStatus

Constructors

ManagerStatus

Fields

• sProcs :: [ByteString]
• sState :: [(ByteString, ByteString)]
• sDone :: Int
• sFailed :: Int
• sQueues :: [(ByteString, Integer)]

Instances

Show ManagerStatus

Methods

showsPrec :: Int -> ManagerStatus -> ShowS

show :: ManagerStatus -> String

showList :: [ManagerStatus] -> ShowS

type Middleware m = Manager -> Worker m Value -> Object -> Queue -> m () -> m ()

type Queue = ByteString

data RunningJob

Constructors

RunningJob

Fields

• rjPayload :: Object
• rjQueue :: Queue
• rjRunAt :: UTCTime
• rjThread :: ThreadId

Instances

ToJSON RunningJob

Methods

toJSON :: RunningJob -> Value

toEncoding :: RunningJob -> Encoding

data Signal

Constructors

USR1

TERM

Instances

Read Signal

Methods

readsPrec :: Int -> ReadS Signal

readList :: ReadS [Signal]

readPrec :: ReadPrec Signal

readListPrec :: ReadPrec [Signal]

Show Signal

Methods

showsPrec :: Int -> Signal -> ShowS

show :: Signal -> String

showList :: [Signal] -> ShowS

data Worker m a

Constructors

Worker

Fields

• workerName :: WorkerName
• workerQueue :: Queue
• workerPerform :: a -> m ()

type WorkerName = ByteString

Orphan instances

ToJSON WorkerName

Methods

toJSON :: WorkerName -> Value

toEncoding :: WorkerName -> Encoding

FromJSON WorkerName

Methods

parseJSON :: Value -> Parser WorkerName