Safe Haskell	None
Language	Haskell2010

Data.PowerQueue.Worker.Distributed

Synopsis

Documentation

Constructors

AuthToken
Fields unAuthToken :: Text

Instances

Eq AuthToken Source #
Methods (==) :: AuthToken -> AuthToken -> Bool # (/=) :: AuthToken -> AuthToken -> Bool #
Show AuthToken Source #
Methods showsPrec :: Int -> AuthToken -> ShowS # show :: AuthToken -> String # showList :: [AuthToken] -> ShowS #
Serialize AuthToken Source #
Methods put :: Putter AuthToken # get :: Get AuthToken #

Constructors

AppVersion
Fields unAppVersion :: Word64

Instances

Eq AppVersion Source #
Methods (==) :: AppVersion -> AppVersion -> Bool # (/=) :: AppVersion -> AppVersion -> Bool #
Ord AppVersion Source #
Methods compare :: AppVersion -> AppVersion -> Ordering # (<) :: AppVersion -> AppVersion -> Bool # (<=) :: AppVersion -> AppVersion -> Bool # (>) :: AppVersion -> AppVersion -> Bool # (>=) :: AppVersion -> AppVersion -> Bool # max :: AppVersion -> AppVersion -> AppVersion # min :: AppVersion -> AppVersion -> AppVersion #
Show AppVersion Source #
Methods showsPrec :: Int -> AppVersion -> ShowS # show :: AppVersion -> String # showList :: [AppVersion] -> ShowS #
Serialize AppVersion Source #
Methods put :: Putter AppVersion # get :: Get AppVersion #

Work master configuration

Constructors

WorkMasterConfig
Fields wmc_host :: !Text wmc_port :: !Int wmc_authToken :: !AuthToken reject all client that do not send this token. See `wnc_authToken` wmc_appVersion :: !AppVersion required app version for all clients. See `wnc_appVersion` wmc_errorHook :: !(ServerErrorEvent -> IO ()) a (non-)critical error occured. Useful for logging

Work master errors

Constructors

SeeClientDisconnect
SeeClientBadVersion !AppVersion
SeeInvalidPayload !String

Instances

Eq ServerErrorEvent Source #
Methods (==) :: ServerErrorEvent -> ServerErrorEvent -> Bool # (/=) :: ServerErrorEvent -> ServerErrorEvent -> Bool #
Show ServerErrorEvent Source #
Methods showsPrec :: Int -> ServerErrorEvent -> ShowS # show :: ServerErrorEvent -> String # showList :: [ServerErrorEvent] -> ShowS #

Launch a work master on current thread that will distribute all incoming work on a queue to connecting worker nodes launched via launchWorkNode

Work node configuration

Constructors

Fields

wnc_hostMaster :: !Text
host where the work master is running. See wmc_host
wnc_portMaster :: !Int
port of work master. See wmc_port
wnc_authToken :: !AuthToken
the authentification token. MUST match the masters wmc_authToken!
wnc_appVersion :: !AppVersion
the current app version. MUST match the masters wmc_appVersion!
wnc_errorHook :: !(ClientErrorEvent -> IO ())
a (non-)critical error occured. Useful for logging
wnc_readyHook :: !(IO ())
called once when ready for draining

Work node async errors

Constructors

CeeConnClosed
CeeBadAuthResponse
CeeInvalidAuthResponse
CeeInvalidDrainResponse
CeeServerBadVersion !AppVersion
CeeInvalidPayload !String
CeeWorkerException !String

Instances

Eq ClientErrorEvent Source #
Methods (==) :: ClientErrorEvent -> ClientErrorEvent -> Bool # (/=) :: ClientErrorEvent -> ClientErrorEvent -> Bool #
Show ClientErrorEvent Source #
Methods showsPrec :: Int -> ClientErrorEvent -> ShowS # show :: ClientErrorEvent -> String # showList :: [ClientErrorEvent] -> ShowS #

Launch a worker node on the current thread connecting to a work master launched with launchWorkMaster

Arguments

:: Serialize j
=> WorkNodeConfig
-> (TimeSpan -> IO ())	callback: will retry in `TimeSpan`. Useful for logging
-> QueueWorker j
-> IO ()