Safe Haskell	None
Language	GHC2024

Arbiter.Test.RateLimit

Description

Backend-parameterized integration tests for per-job rate limiting. Each backend supplies a runner over the shared RLReg registry.

Synopsis

data RLPayload = RLPayload {
- rlTenant :: Text
- rlCost :: Double
}
type RLReg = '[Queue "arbiter_ratelimit_test" RLPayload]
rateLimitTable :: Text
setupRateLimitPolicy :: ByteString -> Text -> IO ()
rateLimitSpec :: forall env m. HasRegistry m RLReg => (forall a. env -> m a -> IO a) -> SpecWith env

Documentation

Source #data RLPayload

A payload keyed by tenant, with a per-job token cost.

Constructors

RLPayload
Fields rlTenant :: Text rlCost :: Double

Instances

Instances details

FromJSON RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

Methods

#parseJSON :: Value -> Parser RLPayload

#parseJSONList :: Value -> Parser [RLPayload]

#omittedField :: Maybe RLPayload

ToJSON RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

Methods

#toJSON :: RLPayload -> Value

#toEncoding :: RLPayload -> Encoding

#toJSONList :: [RLPayload] -> Value

#toEncodingList :: [RLPayload] -> Encoding

#omitField :: RLPayload -> Bool

HasRateLimit RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

Methods

#rateLimitFor :: RateLimitFor RLPayload

#rateLimitCost :: RLPayload -> Double

Eq RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

Methods

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

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

Generic RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

Associated Types

type Rep RLPayload

Instance details

Defined in Arbiter.Test.RateLimit

type Rep RLPayload = D1 ('MetaData "RLPayload" "Arbiter.Test.RateLimit" "arbiter-test-common-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RLPayload" 'PrefixI 'True) (S1 ('MetaSel ('Just "rlTenant") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "rlCost") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double)))

Methods

#from :: RLPayload -> Rep RLPayload x

#to :: Rep RLPayload x -> RLPayload

Show RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

Methods

#showsPrec :: Int -> RLPayload -> ShowS

#show :: RLPayload -> String

#showList :: [RLPayload] -> ShowS

type Rep RLPayload Source #

Instance details

Defined in Arbiter.Test.RateLimit

type Rep RLPayload = D1 ('MetaData "RLPayload" "Arbiter.Test.RateLimit" "arbiter-test-common-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RLPayload" 'PrefixI 'True) (S1 ('MetaSel ('Just "rlTenant") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "rlCost") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double)))

Source #type RLReg = '[Queue "arbiter_ratelimit_test" RLPayload]

A one-queue registry over RLPayload.

Source #rateLimitTable :: Text

Table name for RLReg, shared across backends.

Source #setupRateLimitPolicy :: ByteString -> Text -> IO ()

Upsert the registry's reflected policy rows into a schema.

Source #rateLimitSpec :: forall env m. HasRegistry m RLReg => (forall a. env -> m a -> IO a) -> SpecWith env

The rate-limit suite, run against any backend.