Safe Haskell	None
Language	GHC2024

Arbiter.Test.ConcurrencyLimit

Description

Backend-parameterized integration tests for per-job concurrency limits over the shared CLReg registry. Each job's key comes from the 'HasConcurrency CLPayload' instance.

Synopsis

newtype CLPayload = CLPayload Text
type CLReg = '[Queue "arbiter_concurrency_test" CLPayload]
concurrencyTable :: Text
concurrencyLimitSpec :: forall env m. HasRegistry m CLReg => (forall a. env -> m a -> IO a) -> SpecWith env

Documentation

Source #newtype CLPayload

A payload declaring one concurrency pool.

Constructors

CLPayload Text

Instances

Instances details

FromJSON CLPayload Source #

Instance details

Defined in Arbiter.Test.ConcurrencyLimit

Methods

#parseJSON :: Value -> Parser CLPayload

#parseJSONList :: Value -> Parser [CLPayload]

#omittedField :: Maybe CLPayload

ToJSON CLPayload Source #

Instance details

Defined in Arbiter.Test.ConcurrencyLimit

Methods

#toJSON :: CLPayload -> Value

#toEncoding :: CLPayload -> Encoding

#toJSONList :: [CLPayload] -> Value

#toEncodingList :: [CLPayload] -> Encoding

#omitField :: CLPayload -> Bool

HasConcurrency CLPayload Source #

Instance details

Defined in Arbiter.Test.ConcurrencyLimit

Methods

#concurrencyFor :: ConcurrencyFor CLPayload

Eq CLPayload Source #

Instance details

Defined in Arbiter.Test.ConcurrencyLimit

Methods

#(==) :: CLPayload -> CLPayload -> Bool

#(/=) :: CLPayload -> CLPayload -> Bool

Generic CLPayload Source #

Instance details

Defined in Arbiter.Test.ConcurrencyLimit

Associated Types

type Rep CLPayload
Instance details Defined in Arbiter.Test.ConcurrencyLimit type Rep CLPayload = D1 ('MetaData "CLPayload" "Arbiter.Test.ConcurrencyLimit" "arbiter-test-common-0.1.0.0-inplace" 'True) (C1 ('MetaCons "CLPayload" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))