Fields

• serverEnv :: SimpleEnv registry

  The SimpleEnv containing schema and connection pool

• enableSSE :: Bool

  Enable the Server-Sent Events streaming endpoint. When False, the /events/stream endpoint returns one "disabled" event and closes. The admin UI then polls. Default: True.

• sseHub :: MVar (Maybe SSEHub)

  Lazily started SSE broadcast hub, shared by all clients. The first subscriber starts it. The last disconnect tears it down and releases its LISTEN connection.

• rateLimitPoliciesCache :: CacheCell RateLimitPoliciesResponse

  Short-TTL cache for the rate-limit policy list.

• concurrencyPoliciesCache :: CacheCell ConcurrencyPoliciesResponse

  Short-TTL cache for the concurrency policy list.

• allQueueStatsCache :: CacheCell AllStatsResponse

  Short-TTL cache for the all-queues overview aggregate.

• queueStatsCache :: CacheCell StatsResponse

  Per-queue stats cache.

• queueStatsCacheTtl :: NominalDiffTime

  Per-queue stats staleness, or zero to always hit the database. Default: defaultQueueStatsCacheTtl.

• healthCache :: CacheCell HealthResponse

  Short-TTL cache for the readiness probe.

• maintenanceInterval :: NominalDiffTime

  Minimum gap between runs of one maintenance operation. Zero runs every operation on every call. Default: defaultMaintenanceInterval.

• maintenanceSparseInterval :: NominalDiffTime

  Gap between runs of one whole-schema operation, independent of maintenanceInterval. Default: defaultMaintenanceSparseInterval.

• maintenanceBucketIdle :: NominalDiffTime

  Idle age at which a pass prunes a rate-limit bucket. Default: defaultMaintenanceBucketIdle.

• maintenanceTimeout :: NominalDiffTime

  Abort any single maintenance statement that runs longer than this. Default: defaultMaintenanceTimeout.

Fields

• jobs :: mode :- ("jobs" :> NamedRoutes (JobsAPI payload result :: Type -> Type))
   
• claimJobs :: mode :- ("claim" :> (ReqBody '[JSON] ClaimRequest :> Post '[JSON] (ClaimResponse payload)))
   
• dlq :: mode :- ("dlq" :> NamedRoutes (DLQAPI payload :: Type -> Type))
   
• archive :: mode :- ("archive" :> NamedRoutes (ArchiveAPI payload :: Type -> Type))
   
• stats :: mode :- ("stats" :> NamedRoutes (StatsAPI :: Type -> Type))
   
• listKinds :: mode :- ("kinds" :> Get '[JSON] [Text])
   

Fields

• listQueues :: mode :- Get '[JSON] QueuesResponse
   
• getAllStats :: mode :- ("stats" :> Get '[JSON] AllStatsResponse)
   
• getDetails :: mode :- (Capture "queue" Text :> ("details" :> Get '[JSON] (Maybe QueueRow)))
   
• pauseQueue :: mode :- (Capture "queue" Text :> ("pause" :> PostNoContent))
   
• resumeQueue :: mode :- (Capture "queue" Text :> ("resume" :> PostNoContent))
   

Fields

• listJobs :: mode :- (QueryParam "limit" Int :> (QueryParam "offset" Int :> (QueryParam "group_key" Text :> (QueryParam "parent_id" Int64 :> (QueryParam "job_id" Int64 :> (QueryFlag "roots_only" :> (QueryParam "status" JobStatus :> (QueryParam "claimed_by" UUID :> (QueryParam "kind" Text :> (QueryParam "payload" Text :> (QueryParam "rate_limit_prefix" Text :> (QueryParam "concurrency_prefix" Text :> (QueryParam "sort_by" JobSortColumn :> (QueryParam "sort_dir" SortDir :> Get '[JSON] (JobsResponse payload)))))))))))))))
   
• insertJob :: mode :- (ReqBody '[JSON] (ApiJobWrite payload) :> Post '[JSON] (JobResponse (ApiJob payload)))
   
• insertJobsBatch :: mode :- ("batch" :> (ReqBody '[JSON] (BatchInsertRequest payload) :> Post '[JSON] (BatchInsertResponse payload)))
   
• getJob :: mode :- (Capture "id" Int64 :> Get '[JSON] (JobResponse (ApiJobWithStatus payload)))
   
• cancelJob :: mode :- (Capture "id" Int64 :> DeleteNoContent)
   
• forceCancelJob :: mode :- (Capture "id" Int64 :> ("force-cancel" :> PostNoContent))
   
• ackClaimedJob :: mode :- (Capture "id" Int64 :> ("ack" :> (ReqBody '[JSON] (AckRequest result) :> PostNoContent)))
   
• nackClaimedJob :: mode :- (Capture "id" Int64 :> ("nack" :> (ReqBody '[JSON] JobLease :> PostNoContent)))
   
• extendClaimedJob :: mode :- (Capture "id" Int64 :> ("extend" :> (ReqBody '[JSON] ExtendRequest :> PostNoContent)))
   
• promoteJob :: mode :- (Capture "id" Int64 :> ("promote" :> PostNoContent))
   
• moveToDLQ :: mode :- (Capture "id" Int64 :> ("move-to-dlq" :> PostNoContent))
   
• pauseChildren :: mode :- (Capture "id" Int64 :> ("pause-children" :> PostNoContent))
   
• resumeChildren :: mode :- (Capture "id" Int64 :> ("resume-children" :> PostNoContent))
   
• suspendJob :: mode :- (Capture "id" Int64 :> ("suspend" :> PostNoContent))
   
• resumeJob :: mode :- (Capture "id" Int64 :> ("resume" :> PostNoContent))
   

Fields

• listDLQ :: mode :- (QueryParam "limit" Int :> (QueryParam "offset" Int :> (QueryParam "parent_id" Int64 :> (QueryParam "job_id" Int64 :> (QueryParam "group_key" Text :> (QueryParam "kind" Text :> (QueryParam "sort_by" DLQSortColumn :> (QueryParam "sort_dir" SortDir :> Get '[JSON] (DLQResponse payload)))))))))
   
• retryFromDLQ :: mode :- (Capture "id" Int64 :> ("retry" :> PostNoContent))
   
• deleteDLQ :: mode :- (Capture "id" Int64 :> DeleteNoContent)
   
• deleteDLQBatch :: mode :- ("batch-delete" :> (ReqBody '[JSON] BatchDeleteRequest :> Post '[JSON] BatchDeleteResponse))
   

Fields

• listArchive :: mode :- (QueryParam "limit" Int :> (QueryParam "offset" Int :> (QueryParam "parent_id" Int64 :> (QueryParam "job_id" Int64 :> (QueryParam "group_key" Text :> (QueryParam "kind" Text :> (QueryParam "completed_after" UTCTime :> (QueryParam "completed_before" UTCTime :> (QueryParam "sort_by" ArchiveSortColumn :> (QueryParam "sort_dir" SortDir :> Get '[JSON] (ArchiveResponse payload)))))))))))
   
• reEnqueueArchive :: mode :- (Capture "id" Int64 :> ("reenqueue" :> PostNoContent))
   
• deleteArchive :: mode :- (Capture "id" Int64 :> DeleteNoContent)
   
• deleteArchiveBatch :: mode :- ("batch-delete" :> (ReqBody '[JSON] BatchDeleteRequest :> Post '[JSON] BatchDeleteResponse))
   

Fields

• getStats :: mode :- Get '[JSON] StatsResponse
   

Fields

• runMaintenance :: mode :- Post '[JSON] MaintenanceResponse
   

Fields

• listSchedules :: mode :- ("schedules" :> (QueryParam "queue" Text :> Get '[JSON] CronSchedulesResponse))
   
• updateSchedule :: mode :- ("schedules" :> (Capture "name" Text :> (ReqBody '[JSON] CronScheduleUpdate :> Patch '[JSON] CronScheduleView)))
   
• runSchedule :: mode :- ("schedules" :> (Capture "name" Text :> ("run" :> PostNoContent)))
   

Fields

• listWorkers :: mode :- (QueryParam "queue" Text :> (QueryParam "live" Double :> Get '[JSON] WorkersResponse))
   
• pauseWorker :: mode :- (Capture "id" UUID :> ("pause" :> PostNoContent))
   
• resumeWorker :: mode :- (Capture "id" UUID :> ("resume" :> PostNoContent))
   

Fields

• getHealth :: mode :- Get '[JSON] HealthResponse
   
• getLiveness :: mode :- ("live" :> Get '[JSON] LivenessResponse)
   

Fields

• listRateLimits :: mode :- Get '[JSON] RateLimitPoliciesResponse
   
• listRateLimitBuckets :: mode :- (Capture "prefix" Text :> ("buckets" :> (QueryParam "limit" Int :> (QueryParam "offset" Int :> Get '[JSON] RateLimitBucketsResponse))))
   
• updateRateLimitPolicy :: mode :- (Capture "prefix" Text :> (ReqBody '[JSON] RateLimitPolicyUpdate :> Patch '[JSON] RateLimitPolicyView))
   
• resetRateLimitBuckets :: mode :- (Capture "prefix" Text :> ("reset" :> Post '[JSON] RateLimitResetResponse))
   

Fields

• listConcurrency :: mode :- Get '[JSON] ConcurrencyPoliciesResponse
   
• listConcurrencyKeys :: mode :- (Capture "prefix" Text :> ("keys" :> (QueryParam "limit" Int :> (QueryParam "offset" Int :> Get '[JSON] ConcurrencyKeysResponse))))
   
• updateConcurrencyPolicy :: mode :- (Capture "prefix" Text :> (ReqBody '[JSON] ConcurrencyPolicyUpdate :> Patch '[JSON] ConcurrencyPolicyView))
   
• reconcileConcurrency :: mode :- ("reconcile" :> Post '[JSON] ConcurrencyReconcileResponse)