| cancelJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| cancelJobCascade | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| cancelJobCascadeSQL | Arbiter.Core.Sql.Tree |
| cancelJobsBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| cancelJobSQL | Arbiter.Core.Sql.Jobs |
| cancelJobTree | Arbiter.Core.Operations |
| cancelJobTreeSQL | Arbiter.Core.Sql.Tree |
| Cancelled | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| cancelledJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| cancelNotifyChannel | Arbiter.Core.Job.Schema, Arbiter.Core |
| capturingContext | Arbiter.Core.Trace |
| capturingContextIO | Arbiter.Core.Trace |
| cArray | Arbiter.Core.Codec, Arbiter.Core |
| cascadeChildrenToDLQSQL | Arbiter.Core.Sql.DLQ |
| CBool | Arbiter.Core.Codec, Arbiter.Core |
| cColumns | Arbiter.Core.Codec, Arbiter.Core |
| CFloat8 | Arbiter.Core.Codec, Arbiter.Core |
| checkGateSQL | Arbiter.Core.Sql.Gates |
| chooseWhen | Arbiter.Core.Selector, Arbiter.Core.RateLimit.Spec, Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency, Arbiter.RateLimit |
| CInt4 | Arbiter.Core.Codec, Arbiter.Core |
| CInt8 | Arbiter.Core.Codec, Arbiter.Core |
| CJsonb | Arbiter.Core.Codec, Arbiter.Core |
| ckPrefix | Arbiter.Core.Concurrency.Spec |
| ckSuffix | Arbiter.Core.Concurrency.Spec |
| claimablePred | Arbiter.Core.Sql.Jobs |
| ClaimAdmission | |
| 1 (Type/Class) | Arbiter.Core.Sql.Claim |
| 2 (Data Constructor) | Arbiter.Core.Sql.Claim |
| claimCronRun | Arbiter.Core.Operations |
| claimCronRunSQL | Arbiter.Core.Sql.Cron |
| claimedBy | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| claimJobsBatchedCached | Arbiter.Core.Operations |
| claimJobsBatchedSQL | Arbiter.Core.Sql.Claim |
| claimJobsCached | Arbiter.Core.Operations |
| claimNextVisibleJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| claimNextVisibleJobsAs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| claimNextVisibleJobsBatched | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| claimOrReadGateSQL | Arbiter.Core.Sql.Gates |
| ClaimSeq | Arbiter.Core.Job.Types, Arbiter.Core |
| claimSeq | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| ClaimTime | Arbiter.Core.Job.Types, Arbiter.Core |
| clearConcurrencyLimit | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| clearFailure | Arbiter.Core.FailureGate |
| clearRateLimit | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| Codec | Arbiter.Core.Codec, Arbiter.Core |
| codecColumns | Arbiter.Core.Codec, Arbiter.Core |
| Col | Arbiter.Core.Codec, Arbiter.Core |
| col | Arbiter.Core.Codec, Arbiter.Core |
| CollectFor | Arbiter.Core.Admission |
| collectFor | Arbiter.Core.Admission |
| collectPolicies | Arbiter.Core.Selector, Arbiter.Core.RateLimit.Spec, Arbiter.Core.Concurrency.Spec |
| completedAt | Arbiter.Core.Job.Archive, Arbiter.Core |
| concHeadroomPred | Arbiter.Core.Sql.Claim |
| concurrencyAdvisoryLockExpr | Arbiter.Core.Concurrency.Schema |
| concurrencyBy | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyByCase | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyCountsStaleSQL | Arbiter.Core.Sql.Concurrency |
| ConcurrencyFor | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyFor | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyHasAnyKeySQL | Arbiter.Core.Sql.Concurrency |
| ConcurrencyKey | |
| 1 (Type/Class) | Arbiter.Core.Concurrency.Spec |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Spec |
| concurrencyKey | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| concurrencyKeyText | Arbiter.Core.Concurrency.Spec |
| ConcurrencyKeyView | |
| 1 (Type/Class) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| concurrencyKeyViewCodec | Arbiter.Core.Codec, Arbiter.Core |
| concurrencyPoliciesSQL | Arbiter.Core.Sql.Concurrency |
| ConcurrencyPolicy | |
| 1 (Type/Class) | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Spec |
| ConcurrencyPolicyUpdate | |
| 1 (Type/Class) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| ConcurrencyPolicyView | |
| 1 (Type/Class) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| concurrencyPolicyViewCodec | Arbiter.Core.Codec, Arbiter.Core |
| concurrencyPool | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyPrefix | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| connActive | Arbiter.Core.Health |
| ConnBad | Arbiter.Core.Listen.Driver |
| connBlocked | Arbiter.Core.Health |
| ConnectDriver | |
| 1 (Type/Class) | Arbiter.Core.Listen.Driver |
| 2 (Data Constructor) | Arbiter.Core.Listen.Driver |
| connectionPool | Arbiter.Core.Backend |
| connectPoll | Arbiter.Core.Listen.Driver |
| connectStart | Arbiter.Core.Listen.Driver |
| connIdle | Arbiter.Core.Health |
| connIdleInTxn | Arbiter.Core.Health |
| connIdleInTxnAborted | Arbiter.Core.Health |
| ConnOk | Arbiter.Core.Listen.Driver |
| connOther | Arbiter.Core.Health |
| ConnPending | Arbiter.Core.Listen.Driver |
| ConnStatus | Arbiter.Core.Listen.Driver |
| constructorKind | Arbiter.Core.Job.Kind, Arbiter.Core.Job.Types, Arbiter.Core |
| constructorKinds | Arbiter.Core.Job.Kind, Arbiter.Core.Job.Types, Arbiter.Core |
| ConsumeShape | Arbiter.Core.Trace |
| ConsumeSpan | Arbiter.Core.Trace |
| consumeSpanFor | Arbiter.Core.Trace |
| countArchiveFiltered | Arbiter.Core.Operations |
| countArchiveFilteredSQL | Arbiter.Core.Sql.Archive |
| countChildrenBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countChildrenBatchSQL | Arbiter.Core.Sql.Stats |
| countDLQChildren | Arbiter.Core.HighLevel, Arbiter.Core |
| countDLQChildrenBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countDLQChildrenBatchSQL | Arbiter.Core.Sql.DLQ |
| countDLQFiltered | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countDLQFilteredSQL | Arbiter.Core.Sql.Jobs |
| countDLQJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countDLQJobsByParent | Arbiter.Core.Operations |
| countJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countJobsByGroup | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countJobsByParent | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countJobsFiltered | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countJobsFilteredSQL | Arbiter.Core.Sql.Jobs |
| countOr0 | Arbiter.Core.MonadArbiter, Arbiter.Core |
| countOr0Prepared | Arbiter.Core.MonadArbiter, Arbiter.Core |
| cpLimit | Arbiter.Core.Concurrency.Spec |
| cpPrefix | Arbiter.Core.Concurrency.Spec |
| createArchiveCompletedAtIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createArchiveExpiresAtIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createArchiveGroupKeyIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createArchiveJobIdIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createArchiveParentIdIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createConcurrencyIndexSQL | Arbiter.Core.Concurrency.Schema |
| createConcurrencyPoliciesTableSQL | Arbiter.Core.Concurrency.Schema |
| createConcurrencyTableSQL | Arbiter.Core.Concurrency.Schema |
| createConcurrencyTriggerFunctionsSQL | Arbiter.Core.Concurrency.Schema |
| createConcurrencyTriggersSQL | Arbiter.Core.Concurrency.Schema |
| createCronSchedulesTableSQL | Arbiter.Core.CronSchedule |
| createdAt | |
| 1 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core |
| 2 (Function) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| createDedupKeyIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createDLQFailedAtIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createDLQGroupKeyIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createDLQParentIdIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createEnvWithConfig | Arbiter.Core.Backend |
| createEnvWithPool | Arbiter.Core.Backend |
| createEventStreamingFunctionSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createEventStreamingTriggersSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createGatesTableSQL | Arbiter.Core.Gates |
| createGroupsEmptiedIndexSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createGroupsTableSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createGroupsTriggerFunctionsSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createGroupsTriggersSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createJobQueueArchiveTableSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createJobQueueDLQTableSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createJobQueueGroupedDueIndexSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createJobQueueGroupInFlightIndexSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createJobQueueGroupKeyIndexSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createJobQueueGroupRetriedIndexSQL | Arbiter.Core.Job.Schema.Groups, Arbiter.Core |
| createJobQueueTableSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createMaintenanceTriggersSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createNotifyFunctionSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createNotifyTriggerSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createParentIdIndexSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createQueuesTableSQL | Arbiter.Core.Queues |
| createRateLimitBucketTriggerFunctionsSQL | Arbiter.Core.RateLimit.Schema |
| createRateLimitBucketTriggersSQL | Arbiter.Core.RateLimit.Schema |
| createRateLimitPoliciesTableSQL | Arbiter.Core.RateLimit.Schema |
| createRateLimitsTableSQL | Arbiter.Core.RateLimit.Schema |
| createResultsTableSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createSchemaSQL | Arbiter.Core.Job.Schema, Arbiter.Core |
| createThrottledIndexSQL | Arbiter.Core.RateLimit.Schema |
| createWorkersTableSQL | Arbiter.Core.Worker |
| cronRunNotifyChannel | Arbiter.Core.Job.Schema, Arbiter.Core |
| CronScheduleRow | |
| 1 (Type/Class) | Arbiter.Core.CronSchedule, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.CronSchedule, Arbiter.Core |
| cronScheduleRowCodec | Arbiter.Core.Codec, Arbiter.Core |
| cronSchedulesTable | Arbiter.Core.CronSchedule |
| cronSchedulesTableName | Arbiter.Core.CronSchedule |
| CronScheduleUpdate | |
| 1 (Type/Class) | Arbiter.Core.CronSchedule, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.CronSchedule, Arbiter.Core |
| cScalar | Arbiter.Core.Codec, Arbiter.Core |
| CText | Arbiter.Core.Codec, Arbiter.Core |
| CTimestamptz | Arbiter.Core.Codec, Arbiter.Core |
| CurrentTime | Arbiter.Core.Job.Types, Arbiter.Core |
| currentTraceContext | Arbiter.Core.Trace |
| CUuid | Arbiter.Core.Codec, Arbiter.Core |