Arbiter.RateLimit

A payload's per-job policy selection. Defaults to unlimited. Only limited payloads need an instance.

A selective description of the rate-limit key for a payload. Evaluation returns the job key. Static inspection returns the reachable policies.

A selective description over a payload. Evaluation for a job returns an a. Static inspection returns the reachable policies.

This payload is unlimited.

Limit by a fixed policy, keyed by a per-job suffix, such as a tenant id.

Limit by a fixed policy under one shared key (a single global bucket).

The first selector when the predicate holds, else the second. Policy collection inspects both branches.

N-way chooseWhen. Maps the job to a finite tag, then each tag to its selector. Policy collection evaluates every tag in [minBound..maxBound]. The tag's Bounded/Enum and the selector must be total over k.

The constraint that lets the migration collect a registry's declared policies.

A token-bucket policy. Burst policyMax, refilling continuously at policyRefill per policyInterval. A policyRefill of 0 is a manually-refilled bucket. Fields are non-negative and the interval is positive. The migration rejects other values.

count per period, with a burst of count. The period is floored to a tiny positive value. The prefix must not contain :, the key separator. The migration enforces this.

A policy that admits jobs under a named prefix.

Whether the rate-limit bucket table is WAL-logged. Set by the migration config.

A resolved key with a prefix and per-key suffix. The stored form is prefix:suffix.

A policy with its default and override params plus live bucket and throttle stats. Each effective param is its override* field when set, else its default* field.

A single key's bucket: current tokens, effective max, and fill fraction.

A patch over a policy's override params. Per field: Nothing leaves it unchanged, Just Nothing clears the override (reverts to the default), and Just (Just v) sets it.

Add tokens to a key's bucket, clamped to [0, max], and wake any of its throttled jobs. A key without a bucket gets a full bucket and the amount has no effect. Without a policy the bucket stays unchanged and the wake still runs. Returns the number of jobs woken.

Delete reclaimable idle (full) buckets. Returns the number pruned. The worker pool reaper runs this. A full bucket re-seeds at full on next use.

Reset every bucket for a prefix to full and wake its throttled jobs. Returns the number of buckets reset. A manual (0-refill) policy plus a cron calling this at the boundary is a fixed window.

List every rate-limit policy with its params, bucket stats, and a live count of currently-throttled jobs per prefix across the registry's queues.

List a prefix's buckets with fill levels, emptiest first.

Set or clear a policy's override params and wake the prefix's throttled jobs. Returns rows affected (0 if absent).

Override a policy with this shape, until it is cleared. Returns rows affected.

Drop a policy's overrides. Its declared params apply again. Returns rows affected.

One prefix's rate-limit policy with its params, bucket stats, and live throttled count. Nothing when the prefix has no policy.

Whether a rate-limit policy exists for a prefix.