Faktory.Ent.Batch

Support for the BATCH command (Enterprise only)

https://github.com/contribsys/faktory/wiki/Ent-Batches

Batches allow multiple Jobs to be enqueued as a group, with a description (visible in the admin UI) and Jobs attached to run on completion of all Jobs within the group (always, or only if all were successful).

Usage:

-- Build a Job to run at completion of the Batch. Arguments are the same as
-- you would pass to perform the Job.
onComplete <- buildJob mempty producer myJob

runBatch (complete onComplete <> description "My Batch") producer $ do
  -- Use batchPerform instead of perform
  void $ batchPerform mempty producer myBatchedJob1
  void $ batchPerform mempty producer myBatchedJob2

/NOTE: This module does not support batched Jobs dynamically adding more Jobs to the Batch. PRs welcome.

Options

data BatchOptions arg

Instances

ToJSON arg => ToJSON (BatchOptions arg)

Defined in Faktory.Ent.Batch

Methods

toJSON :: BatchOptions arg -> Value

toEncoding :: BatchOptions arg -> Encoding

toJSONList :: [BatchOptions arg] -> Value

toEncodingList :: [BatchOptions arg] -> Encoding

omitField :: BatchOptions arg -> Bool

Monoid (BatchOptions arg)

Defined in Faktory.Ent.Batch

Methods

mempty :: BatchOptions arg

mappend :: BatchOptions arg -> BatchOptions arg -> BatchOptions arg

mconcat :: [BatchOptions arg] -> BatchOptions arg

Semigroup (BatchOptions arg)

Defined in Faktory.Ent.Batch

Methods

(<>) :: BatchOptions arg -> BatchOptions arg -> BatchOptions arg

sconcat :: NonEmpty (BatchOptions arg) -> BatchOptions arg

stimes :: Integral b => b -> BatchOptions arg -> BatchOptions arg

Generic (BatchOptions arg)

Defined in Faktory.Ent.Batch

Associated Types

type Rep (BatchOptions arg) :: Type -> Type

Methods

from :: BatchOptions arg -> Rep (BatchOptions arg) x

to :: Rep (BatchOptions arg) x -> BatchOptions arg

type Rep (BatchOptions arg)

Defined in Faktory.Ent.Batch

type Rep (BatchOptions arg) = D1 ('MetaData "BatchOptions" "Faktory.Ent.Batch" "faktory-1.1.2.7-2ueK9WlYC3nL6yjpm69v98" 'False) (C1 ('MetaCons "BatchOptions" 'PrefixI 'True) (S1 ('MetaSel ('Just "boDescription") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Last Text))) :*: (S1 ('MetaSel ('Just "boSuccess") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Last (Job arg)))) :*: S1 ('MetaSel ('Just "boComplete") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Last (Job arg)))))))

description :: Text -> BatchOptions arg

complete :: Job arg -> BatchOptions arg

success :: Job arg -> BatchOptions arg

Running

runBatch :: ToJSON arg => BatchOptions arg -> Producer -> Batch a -> IO a

data Batch a

Instances

MonadIO Batch

Defined in Faktory.Ent.Batch

Methods

liftIO :: IO a -> Batch a

Applicative Batch

Defined in Faktory.Ent.Batch

Methods

pure :: a -> Batch a

(<*>) :: Batch (a -> b) -> Batch a -> Batch b

liftA2 :: (a -> b -> c) -> Batch a -> Batch b -> Batch c

(*>) :: Batch a -> Batch b -> Batch b

(<*) :: Batch a -> Batch b -> Batch a

Functor Batch

Defined in Faktory.Ent.Batch

Methods

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

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

Monad Batch

Defined in Faktory.Ent.Batch

Methods

(>>=) :: Batch a -> (a -> Batch b) -> Batch b

(>>) :: Batch a -> Batch b -> Batch b

return :: a -> Batch a

MonadReader BatchId Batch

Defined in Faktory.Ent.Batch

Methods

ask :: Batch BatchId

local :: (BatchId -> BatchId) -> Batch a -> Batch a

reader :: (BatchId -> a) -> Batch a

batchPerform :: (HasCallStack, ToJSON arg) => JobOptions -> Producer -> arg -> Batch JobId

Low-level

newtype BatchId

Constructors

BatchId Text

Instances

FromJSON BatchId

Defined in Faktory.Ent.Batch

Methods

parseJSON :: Value -> Parser BatchId

parseJSONList :: Value -> Parser [BatchId]

omittedField :: Maybe BatchId

ToJSON BatchId

Defined in Faktory.Ent.Batch

Methods

toJSON :: BatchId -> Value

toEncoding :: BatchId -> Encoding

toJSONList :: [BatchId] -> Value

toEncodingList :: [BatchId] -> Encoding

omitField :: BatchId -> Bool

Show BatchId

Defined in Faktory.Ent.Batch

Methods

showsPrec :: Int -> BatchId -> ShowS

show :: BatchId -> String

showList :: [BatchId] -> ShowS

Eq BatchId

Defined in Faktory.Ent.Batch

Methods

(==) :: BatchId -> BatchId -> Bool

(/=) :: BatchId -> BatchId -> Bool

MonadReader BatchId Batch

Defined in Faktory.Ent.Batch

Methods

ask :: Batch BatchId

local :: (BatchId -> BatchId) -> Batch a -> Batch a

reader :: (BatchId -> a) -> Batch a

newtype CustomBatchId

Constructors

CustomBatchId

Fields

• bid :: BatchId

Instances

ToJSON CustomBatchId

Defined in Faktory.Ent.Batch

Methods

toJSON :: CustomBatchId -> Value

toEncoding :: CustomBatchId -> Encoding

toJSONList :: [CustomBatchId] -> Value

toEncodingList :: [CustomBatchId] -> Encoding

omitField :: CustomBatchId -> Bool

Generic CustomBatchId

Defined in Faktory.Ent.Batch

Associated Types

type Rep CustomBatchId :: Type -> Type

Methods

from :: CustomBatchId -> Rep CustomBatchId x

to :: Rep CustomBatchId x -> CustomBatchId

type Rep CustomBatchId

Defined in Faktory.Ent.Batch

type Rep CustomBatchId = D1 ('MetaData "CustomBatchId" "Faktory.Ent.Batch" "faktory-1.1.2.7-2ueK9WlYC3nL6yjpm69v98" 'True) (C1 ('MetaCons "CustomBatchId" 'PrefixI 'True) (S1 ('MetaSel ('Just "bid") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 BatchId)))

newBatch :: ToJSON arg => Producer -> BatchOptions arg -> IO BatchId

commitBatch :: Producer -> BatchId -> IO ()