| <~~ | Arbiter.Core.JobTree, Arbiter.Core |
| ackJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| ackJobsBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| ackJobsBatchWith | Arbiter.Core.Operations |
| ackJobWith | Arbiter.Core.Operations |
| AckStatements | Arbiter.Core.Operations |
| addArchiveForColumnSQL | Arbiter.Core.Job.Schema |
| addCancelRequestedAtColumnSQL | Arbiter.Core.Job.Schema |
| addClaimedByColumnSQL | Arbiter.Core.Job.Schema |
| addClaimSeqColumnSQL | Arbiter.Core.Job.Schema |
| addConcurrencyColumnsSQL | Arbiter.Core.Concurrency.Schema |
| addDLQRetentionColumnSQL | Arbiter.Core.Queues |
| addGateMetadataColumnSQL | Arbiter.Core.Gates |
| addKindColumnSQL | Arbiter.Core.Job.Schema |
| addLastManualRunColumnSQL | Arbiter.Core.CronSchedule |
| addQueueNameColumnSQL | Arbiter.Core.CronSchedule |
| addRateLimitColumnsSQL | Arbiter.Core.RateLimit.Schema |
| addRateLimitCostColumnSQL | Arbiter.Core.RateLimit.Schema |
| addRateLimitTokens | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| addRateLimitTokensSQL | Arbiter.Core.Sql.RateLimit |
| addRunRequestedColumnSQL | Arbiter.Core.CronSchedule |
| addTimezoneColumnSQL | Arbiter.Core.CronSchedule |
| addTraceContextColumnSQL | Arbiter.Core.Job.Schema |
| AdmissionPolicy | Arbiter.Core.Admission, Arbiter.Concurrency, Arbiter.RateLimit |
| admitConcurrent | Arbiter.Core.Sql.Claim |
| admitRateLimited | Arbiter.Core.Sql.Claim |
| advisoryXactLockManySQL | Arbiter.Core.Sql.Tree |
| allQueueStatsSQL | Arbiter.Core.Sql.Stats |
| AllQueuesUnique | Arbiter.Core.QueueRegistry, Arbiter.Core |
| allSchemaTables | Arbiter.Core.SchemaTables |
| alterRateLimitsDurabilitySQL | Arbiter.Core.RateLimit.Schema |
| andThen | Arbiter.Core.Job.Types, Arbiter.Core |
| arbiterConcurrencyPoliciesTable | Arbiter.Core.Concurrency.Schema |
| arbiterConcurrencyPoliciesTableName | Arbiter.Core.Concurrency.Schema |
| arbiterConcurrencyTable | Arbiter.Core.Concurrency.Schema |
| arbiterConcurrencyTableName | Arbiter.Core.Concurrency.Schema |
| arbiterGatesTable | Arbiter.Core.Gates |
| arbiterGatesTableName | Arbiter.Core.Gates |
| arbiterQueuesTable | Arbiter.Core.Queues |
| arbiterQueuesTableName | Arbiter.Core.Queues |
| arbiterRateLimitPoliciesTable | Arbiter.Core.RateLimit.Schema |
| arbiterRateLimitPoliciesTableName | Arbiter.Core.RateLimit.Schema |
| arbiterRateLimitsTable | Arbiter.Core.RateLimit.Schema |
| arbiterRateLimitsTableName | Arbiter.Core.RateLimit.Schema |
| arbiterWorkersTable | Arbiter.Core.Worker |
| arbiterWorkersTableName | Arbiter.Core.Worker |
| archiveAckCte | Arbiter.Core.Sql.Archive |
| ArchiveAttempts | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| ArchiveCompletedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| archivedResult | Arbiter.Core.Job.Archive, Arbiter.Core |
| archiveFor | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| ArchiveGroupKey | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| ArchiveId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| ArchiveInsertedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| ArchiveJob | |
| 1 (Type/Class) | Arbiter.Core.Job.Archive, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.Archive, Arbiter.Core |
| ArchiveJobId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| ArchiveParentId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| archivePrimaryKey | Arbiter.Core.Job.Archive, Arbiter.Core |
| archiveRowCodec | Arbiter.Core.Codec |
| archivesOnAck | Arbiter.Core.Operations |
| ArchiveSortColumn | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| archiveSortColumnName | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| ArchiveTable | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| attempts | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| attemptsLeftSQL | Arbiter.Core.SqlLiterals |
| attemptsSpentSQL | Arbiter.Core.SqlLiterals |
| avgTokens | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| Backoff | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| BackoffDelay | Arbiter.Core.Job.Types, Arbiter.Core |
| backoffJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| batchFrag | Arbiter.Core.Sql.Insert |
| beginSpawnSQL | Arbiter.Core.Sql.Tree |
| blksHit | Arbiter.Core.Health |
| blksRead | Arbiter.Core.Health |
| blockedJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| BranchCancel | Arbiter.Core.Exceptions, Arbiter.Core |
| BranchCancelException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| bucketCount | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| bucketSeedInsert | Arbiter.Core.RateLimit.Schema |
| buildArchiveOrderBy | Arbiter.Core.Sql.Jobs |
| buildDLQOrderBy | Arbiter.Core.Sql.Jobs |
| buildJobsOrderBy | Arbiter.Core.Sql.Jobs |
| buildWhereClause | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| bumpGateSQL | Arbiter.Core.Sql.Gates |
| bumpGateStateSQL | Arbiter.Core.Sql.Gates |
| 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 |
| CancelledScope | Arbiter.Core.Operations |
| cancelNotifyChannel | Arbiter.Core.Job.Schema |
| cancelTokenBump | Arbiter.Core.Sql.Tree, Arbiter.Core.Operations |
| capturingContext | Arbiter.Core.Trace |
| capturingContextIO | Arbiter.Core.Trace |
| cArray | Arbiter.Core.Codec |
| cascadeChildrenToDLQSQL | Arbiter.Core.Sql.DLQ |
| CBool | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| cColumns | Arbiter.Core.Codec |
| CFloat8 | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| checkGateSQL | Arbiter.Core.Sql.Gates |
| childDescendantsCte | Arbiter.Core.Sql.Tree |
| chooseWhen | Arbiter.Core.Selector, Arbiter.Core.RateLimit.Spec, Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency, Arbiter.RateLimit |
| CInt4 | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| CInt8 | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| CJsonb | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| ckPrefix | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| ckSuffix | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| 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 |
| codecColumns | Arbiter.Core.Codec |
| Col | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| col | Arbiter.Core.Codec |
| 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, Arbiter.Concurrency |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| 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 |
| concurrencyPoliciesSQL | Arbiter.Core.Sql.Concurrency |
| ConcurrencyPolicy | |
| 1 (Type/Class) | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| 2 (Data Constructor) | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyPolicy | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| concurrencyPolicyExists | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| concurrencyPolicyExistsSQL | Arbiter.Core.Sql.Concurrency |
| 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 |
| 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 |
| connectErrorMessage | Arbiter.Core.Listen.Driver |
| connectFinish | Arbiter.Core.Listen.Driver |
| connectionPool | Arbiter.Core.Backend |
| connectPoll | Arbiter.Core.Listen.Driver |
| connectStart | Arbiter.Core.Listen.Driver |
| connectStatus | 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 | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| 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.DLQ |
| countDLQJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| countDLQJobsByParent | Arbiter.Core.Operations |
| countGroups | Arbiter.Core.Operations |
| countGroupsSQL | Arbiter.Core.Sql.Stats |
| 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 |
| countOr0Prepared | Arbiter.Core.MonadArbiter |
| countWhereSQL | Arbiter.Core.Sql.Jobs |
| cpLimit | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| cpPrefix | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| createArchiveCompletedAtIndexSQL | Arbiter.Core.Job.Schema |
| createArchiveExpiresAtIndexSQL | Arbiter.Core.Job.Schema |
| createArchiveGroupKeyIndexSQL | Arbiter.Core.Job.Schema |
| createArchiveJobIdIndexSQL | Arbiter.Core.Job.Schema |
| createArchiveParentIdIndexSQL | Arbiter.Core.Job.Schema |
| 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.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| createDedupKeyIndexSQL | Arbiter.Core.Job.Schema |
| createDLQFailedAtIndexSQL | Arbiter.Core.Job.Schema |
| createDLQGroupKeyIndexSQL | Arbiter.Core.Job.Schema |
| createDLQParentIdIndexSQL | Arbiter.Core.Job.Schema |
| createEnvWithConfig | Arbiter.Core.Backend |
| createEnvWithPool | Arbiter.Core.Backend |
| createEventStreamingFunctionSQL | Arbiter.Core.Job.Schema |
| createEventStreamingTriggersSQL | Arbiter.Core.Job.Schema |
| createGatesTableSQL | Arbiter.Core.Gates |
| createGroupsEmptiedIndexSQL | Arbiter.Core.Job.Schema.Groups |
| createGroupsTableSQL | Arbiter.Core.Job.Schema.Groups |
| createGroupsTriggerFunctionsSQL | Arbiter.Core.Job.Schema.Groups |
| createGroupsTriggersSQL | Arbiter.Core.Job.Schema.Groups |
| createJobQueueArchiveTableSQL | Arbiter.Core.Job.Schema |
| createJobQueueDLQTableSQL | Arbiter.Core.Job.Schema |
| createJobQueueGroupedDueIndexSQL | Arbiter.Core.Job.Schema.Groups |
| createJobQueueGroupInFlightIndexSQL | Arbiter.Core.Job.Schema.Groups |
| createJobQueueGroupKeyIndexSQL | Arbiter.Core.Job.Schema.Groups |
| createJobQueueGroupRetriedIndexSQL | Arbiter.Core.Job.Schema.Groups |
| createJobQueueTableSQL | Arbiter.Core.Job.Schema |
| createMaintenanceTriggersSQL | Arbiter.Core.Job.Schema |
| createNotifyFunctionSQL | Arbiter.Core.Job.Schema |
| createNotifyTriggerSQL | Arbiter.Core.Job.Schema |
| createParentIdIndexSQL | Arbiter.Core.Job.Schema |
| 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 |
| createSchemaSQL | Arbiter.Core.Job.Schema |
| createThrottledIndexSQL | Arbiter.Core.RateLimit.Schema |
| createWorkersTableSQL | Arbiter.Core.Worker |
| cronRunNotifyChannel | Arbiter.Core.Job.Schema |
| CronScheduleRow | |
| 1 (Type/Class) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| cronScheduleRowCodec | Arbiter.Core.Codec |
| cronSchedulesTable | Arbiter.Core.CronSchedule |
| cronSchedulesTableName | Arbiter.Core.CronSchedule |
| CronScheduleUpdate | |
| 1 (Type/Class) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| cScalar | Arbiter.Core.Codec |
| CStored | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| CText | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| CTimestamptz | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| CurrentTime | Arbiter.Core.Job.Types, Arbiter.Core |
| currentTraceContext | Arbiter.Core.Trace |
| CUuid | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| dayRetention | Arbiter.Core.Job.Types, Arbiter.Core |
| Db | |
| 1 (Type/Class) | Arbiter.Core.Backend |
| 2 (Data Constructor) | Arbiter.Core.Backend |
| deadLetterRejected | Arbiter.Core.Operations |
| deadTup | Arbiter.Core.Health |
| decodeJobResult | Arbiter.Core.JobResult, Arbiter.Core |
| decodeOrEmpty | Arbiter.Core.Json |
| decodeRow | Arbiter.Core.Operations |
| decodeStored | Arbiter.Core.Job.Types, Arbiter.Core |
| dedupFromParts | Arbiter.Core.Job.Dedup |
| dedupFromStrategy | Arbiter.Core.Job.Dedup |
| DedupKey | Arbiter.Core.Job.Dedup, Arbiter.Core.Job.Types, Arbiter.Core |
| dedupKey | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| dedupParts | Arbiter.Core.Job.Dedup, Arbiter.Core.Job.Types |
| dedupStrategyText | Arbiter.Core.Job.Dedup |
| defaultExpression | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| defaultFailureRepeatInterval | Arbiter.Core.FailureGate |
| defaultGroupedJob | Arbiter.Core.Job.Types, Arbiter.Core |
| defaultInterval | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| defaultJob | Arbiter.Core.Job.Types, Arbiter.Core |
| defaultLimit | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| defaultMaxAttempts | Arbiter.Core.Job.Types, Arbiter.Core |
| defaultMaxAttemptsSQL | Arbiter.Core.SqlLiterals |
| defaultMaxTokens | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| defaultObservabilityHooks | Arbiter.Core.Job.Types, Arbiter.Core |
| defaultOverlap | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| defaultPoolConfig | Arbiter.Core.PoolConfig, Arbiter.Core |
| defaultRefillAmount | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| defaultThrottleWaitSeconds | Arbiter.Core.Sql.RateLimit |
| defaultTimezone | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| deleteArchiveJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| deleteArchiveJobsBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| deleteArchiveJobsBatchSQL | Arbiter.Core.Sql.Archive |
| deleteCancelledJobs | Arbiter.Core.Operations |
| deleteDLQJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| deleteDLQJobsBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| deleteDLQJobsBatchSQL | Arbiter.Core.Sql.DLQ |
| deleteHeldCancelledJobsSQL | Arbiter.Core.Sql.Tree |
| deleteLapsedCancelledJobsSQL | Arbiter.Core.Sql.Tree |
| deleteResultsByParentSQL | Arbiter.Core.Sql.Tree |
| deleteStaleWorkersSQL | Arbiter.Core.Sql.Workers |
| deleteWorkerSQL | Arbiter.Core.Sql.Workers |
| deregisterWorker | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| destroyEnv | Arbiter.Core.Backend |
| detachDLQChildrenSQL | Arbiter.Core.Sql.Tree |
| disableListener | Arbiter.Core.Backend |
| displayEx | Arbiter.Core.Exceptions |
| DlqAttempts | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqCarriedCols | Arbiter.Core.Sql.Jobs |
| DlqFailedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| DlqGroupKey | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| DlqId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqIdsFilteredSQL | Arbiter.Core.Sql.DLQ |
| DlqInsertedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| DLQJob | |
| 1 (Type/Class) | Arbiter.Core.Job.DLQ, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.DLQ, Arbiter.Core |
| dlqJobExists | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| dlqJobExistsSQL | Arbiter.Core.Sql.DLQ |
| DlqJobId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqKindCounts | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| DlqLastAttemptedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| DLQMove | Arbiter.Core.Sql.DLQ |
| DlqParentId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqParentIdsSQL | Arbiter.Core.Sql.DLQ |
| dlqPrimaryKey | Arbiter.Core.Job.DLQ, Arbiter.Core |
| DlqPriority | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqRetention | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqRetryParentSQL | Arbiter.Core.Sql.DLQ |
| dlqRowCodec | Arbiter.Core.Codec |
| DLQSortColumn | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| dlqSortColumnName | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| dlqSuffix | Arbiter.Core.Job.Schema |
| DLQTable | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| dollarQuote | Arbiter.Core.SqlLiterals |
| doubleLiteral | Arbiter.Core.SqlLiterals |
| Draining | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| Driver | |
| 1 (Type/Class) | Arbiter.Core.Backend |
| 2 (Data Constructor) | Arbiter.Core.Backend |
| driverConfig | Arbiter.Core.Backend |
| dropEventStreamingFunctionSQL | Arbiter.Core.Job.Schema |
| Durability | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| Durable | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| editColumns | Arbiter.Core.Sql.Insert |
| editJoin | Arbiter.Core.Sql.Insert |
| editSource | Arbiter.Core.Sql.Insert |
| effectiveExpression | Arbiter.Core.CronSchedule, Arbiter.Core |
| effectiveLimit | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| effectiveOverlap | Arbiter.Core.CronSchedule, Arbiter.Core |
| effectivePolicyCol | Arbiter.Core.Admission |
| effectiveTimezone | Arbiter.Core.CronSchedule, Arbiter.Core |
| emptiedWindowSQL | Arbiter.Core.Sql.Groups |
| enabled | |
| 1 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| EncodeJobResult | Arbiter.Core.JobResult, Arbiter.Core |
| encodeJobResult | Arbiter.Core.JobResult, Arbiter.Core |
| EndTime | Arbiter.Core.Job.Types, Arbiter.Core |
| enqueuedAgainCols | Arbiter.Core.Sql.Jobs |
| enqueuedAgainValsEditing | Arbiter.Core.Sql.Jobs |
| ensureGateRowSQL | Arbiter.Core.Sql.Gates |
| ensureQueue | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| ensureQueueSQL | Arbiter.Core.Sql.Queues |
| enumFromText | Arbiter.Core.Enum |
| enumFromTextCI | Arbiter.Core.Enum |
| Env | |
| 1 (Type/Class) | Arbiter.Core.Backend |
| 2 (Data Constructor) | Arbiter.Core.Backend |
| ErrorMsg | Arbiter.Core.Job.Types, Arbiter.Core |
| eventStreamingAdoptedObjectComment | Arbiter.Core.Job.Schema |
| eventStreamingChannel | Arbiter.Core.Job.Schema |
| eventStreamingDLQTriggerName | Arbiter.Core.Job.Schema |
| eventStreamingFunctionName | Arbiter.Core.Job.Schema |
| eventStreamingObjectComment | Arbiter.Core.Job.Schema |
| eventStreamingObjectCommentPrefix | Arbiter.Core.Job.Schema |
| eventStreamingTriggerName | Arbiter.Core.Job.Schema |
| excludedAssignment | Arbiter.Core.Admission |
| execOutcome | Arbiter.Core.Listen.Driver |
| executeQuery | Arbiter.Core.MonadArbiter, Arbiter.Core |
| executeQueryPrepared | Arbiter.Core.MonadArbiter, Arbiter.Core |
| executeStatement | Arbiter.Core.MonadArbiter, Arbiter.Core |
| Exhausted | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| exhaustedJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| existingQueuesSQL | Arbiter.Core.Sql.Queues |
| failedAt | Arbiter.Core.Job.DLQ, Arbiter.Core |
| FailureGate | Arbiter.Core.FailureGate |
| field | Arbiter.Core.Selector |
| fillFraction | |
| 1 (Function) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| 2 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| FilterClaimedBy | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterCompletedAfter | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterCompletedBefore | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterConcurrencyPrefix | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterErrorText | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterGroupKey | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterInsertedAfter | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterInsertedBefore | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterJobId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterKind | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterParentId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterPayloadText | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterRateLimitPrefix | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterRootsOnly | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterStatus | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| FilterTable | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| forceCancelJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| forceCancelJobSQL | Arbiter.Core.Sql.Tree |
| gateEpochSQL | Arbiter.Core.Gates |
| gateNameDigestSQL | Arbiter.Core.Sql.Gates |
| gateNameFor | Arbiter.Core.Operations |
| getAllQueueStats | Arbiter.Core.Operations |
| getArchiveJobById | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getConcurrencyPolicy | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| getCronScheduleByName | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getCronScheduleByNameSQL | Arbiter.Core.Sql.Cron |
| getDLQChildErrorsByParent | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getDLQChildErrorsByParentSQL | Arbiter.Core.Sql.Tree |
| getJobByDedupKey | Arbiter.Core.Operations |
| getJobByDedupKeySQL | Arbiter.Core.Sql.Jobs |
| getJobById | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getJobByIdSQL | Arbiter.Core.Sql.Jobs |
| getJobByIdWithStatus | Arbiter.Core.Operations |
| getJobByIdWithStatusSQL | Arbiter.Core.Sql.Jobs |
| getListener | Arbiter.Core.MonadArbiter, Arbiter.Core |
| getParentIdsSQL | Arbiter.Core.Sql.Tree |
| getParentStateSnapshot | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getParentStateSnapshotSQL | Arbiter.Core.Sql.Tree |
| getPgDbHealth | Arbiter.Core.Health |
| getPgHealth | Arbiter.Core.Health |
| getPoolState | Arbiter.Core.Backend |
| getQueue | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getQueueSQL | Arbiter.Core.Sql.Queues |
| getQueueStats | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getQueueStatsSQL | Arbiter.Core.Sql.Stats |
| getRateLimitPolicy | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| getResultsByParent | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| getResultsByParentSQL | Arbiter.Core.Sql.Tree |
| getSchema | Arbiter.Core.MonadArbiter, Arbiter.Core.HighLevel, Arbiter.Core |
| GKind | Arbiter.Core.Job.Kind |
| gKindOf | Arbiter.Core.Job.Kind |
| gKindsOf | Arbiter.Core.Job.Kind |
| globalConcurrency | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| globalLimit | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| groupAggregates | Arbiter.Core.Job.Schema.Groups |
| groupHeadBatch | Arbiter.Core.Sql.Claim |
| groupKey | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| GroupsCursor | |
| 1 (Type/Class) | Arbiter.Core.Operations |
| 2 (Data Constructor) | Arbiter.Core.Operations |
| groupsEmptiedFrom | Arbiter.Core.Operations |
| GroupsPass | |
| 1 (Type/Class) | Arbiter.Core.Operations |
| 2 (Data Constructor) | Arbiter.Core.Operations |
| GroupSummary | |
| 1 (Type/Class) | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| groupsWindowFrom | Arbiter.Core.Operations |
| groupsWindowSQL | Arbiter.Core.Sql.Groups |
| gsGroupKey | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsHeadBlocked | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsHeadJobId | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsHeadStatus | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsInFlight | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsInFlightUntil | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsJobCount | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsNextDue | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| gsReadyCount | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| Handler | Arbiter.Core.MonadArbiter, Arbiter.Core, Arbiter.Core |
| HasConcurrency | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| HasKind | Arbiter.Core.Job.Kind, Arbiter.Core.Job.Types, Arbiter.Core |
| HasPoolState | Arbiter.Core.Backend |
| HasRateLimit | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| HasRegistry | Arbiter.Core.MonadArbiter, Arbiter.Core |
| health | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| heartbeatWorker | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| heartbeatWorkerSQL | Arbiter.Core.Sql.Workers |
| HeldBy | Arbiter.Core.Operations |
| hoistObservabilityHooks | Arbiter.Core.Job.Types, Arbiter.Core |
| holdFailure | Arbiter.Core.FailureGate |
| Hole | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| hostName | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| hubError | Arbiter.Core.Listen, Arbiter.Core |
| HubLog | |
| 1 (Type/Class) | Arbiter.Core.Listen, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Listen, Arbiter.Core |
| hubRecovered | Arbiter.Core.Listen, Arbiter.Core |
| hubRepeatInterval | Arbiter.Core.Listen, Arbiter.Core |
| hubWarn | Arbiter.Core.Listen, Arbiter.Core |
| idxScan | Arbiter.Core.Health |
| IgnoreDuplicate | Arbiter.Core.Job.Dedup, Arbiter.Core.Job.Types, Arbiter.Core |
| indexSQL | Arbiter.Core.Job.Schema |
| InFlight | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| inFlight | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| inFlightJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| inFlightPredicate | Arbiter.Core.Job.Schema.Groups |
| initialConfig | Arbiter.Core.Backend |
| insertedAt | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| insertFrag | Arbiter.Core.Sql.Insert |
| insertJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| insertJobReplaceSQL | Arbiter.Core.Sql.Jobs |
| insertJobsBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| insertJobsBatchSQL | Arbiter.Core.Sql.Jobs |
| insertJobsBatchSQL_ | Arbiter.Core.Sql.Jobs |
| insertJobsBatch_ | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| insertJobSQL | Arbiter.Core.Sql.Jobs |
| insertJobTree | |
| 1 (Function) | Arbiter.Core.JobTree |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| insertJobTreeLeavesStamped | Arbiter.Core.Operations |
| insertJobTreeNodeStamped | Arbiter.Core.Operations |
| insertMissingGroupsSQL | Arbiter.Core.Sql.Groups |
| insertResult | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| insertResultsBatch | Arbiter.Core.Operations |
| insertResultsBatchSQL | Arbiter.Core.Sql.Tree |
| insertResultSQL | Arbiter.Core.Sql.Tree |
| insertResultUnsafe | Arbiter.Core.HighLevel, Arbiter.Core |
| instrumentationScope | Arbiter.Core.Trace |
| InternalException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| intLiteral | Arbiter.Core.SqlLiterals |
| inTransaction | Arbiter.Core.Backend |
| isReplaceDuplicate | Arbiter.Core.Job.Dedup |
| isRollup | Arbiter.Core.Job.Types, Arbiter.Core |
| Job | |
| 1 (Type/Class) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.Types.Internal |
| JobCancelled | Arbiter.Core.HighLevel, Arbiter.Core |
| jobCodec | Arbiter.Core.Codec |
| jobColsExceptId | Arbiter.Core.Sql.Jobs |
| jobConcurrencyKey | Arbiter.Core.Job.Types, Arbiter.Core |
| JobDeadlineExceeded | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| JobException | Arbiter.Core.Exceptions, Arbiter.Core |
| jobExists | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| jobExistsSQL | Arbiter.Core.Sql.Tree |
| JobFilter | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JobForceCancelled | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| JobGone | Arbiter.Core.HighLevel, Arbiter.Core |
| JobGoneException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| JobHandler | Arbiter.Core.MonadArbiter, Arbiter.Core |
| JobId | Arbiter.Core.Job.Types, Arbiter.Core |
| jobKind | Arbiter.Core.Job.Types, Arbiter.Core |
| JobNackException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| JobOperation | Arbiter.Core.HighLevel, Arbiter.Core |
| JobPayload | Arbiter.Core.Job.Types, Arbiter.Core |
| JobPayloadRegistry | Arbiter.Core.QueueRegistry, Arbiter.Core |
| JobPermanentException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| jobQueueArchiveTable | Arbiter.Core.Job.Schema |
| jobQueueDLQTable | Arbiter.Core.Job.Schema |
| jobQueueGroupsTable | Arbiter.Core.Job.Schema |
| jobQueueResultsTable | Arbiter.Core.Job.Schema |
| jobQueueTable | Arbiter.Core.Job.Schema |
| jobRateLimitKey | Arbiter.Core.Job.Types, Arbiter.Core |
| JobRead | Arbiter.Core.Job.Types, Arbiter.Core |
| jobReadColumns | Arbiter.Core.Sql.Jobs |
| jobReadPairs | Arbiter.Core.Job.Types, Arbiter.Core |
| jobReadSeries | Arbiter.Core.Job.Types, Arbiter.Core |
| JobReclaimed | Arbiter.Core.HighLevel, Arbiter.Core |
| JobRecord | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types |
| JobRetryableException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| jobRowCodec | Arbiter.Core.Codec |
| JobScopedFailure | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| JobSnapshot | Arbiter.Core.Job.DLQ, Arbiter.Core |
| jobSnapshot | |
| 1 (Function) | Arbiter.Core.Job.DLQ, Arbiter.Core |
| 2 (Function) | Arbiter.Core.Job.Archive, Arbiter.Core |
| JobSortColumn | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| jobSortColumnName | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| JobStatements | Arbiter.Core.Operations |
| JobStatus | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| jobStatusCaseSQL | Arbiter.Core.Sql.Jobs |
| jobStatusFromText | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| jobStatusToText | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| JobSuspended | Arbiter.Core.HighLevel, Arbiter.Core |
| JobTree | Arbiter.Core.JobTree, Arbiter.Core |
| JobWrite | Arbiter.Core.Job.Types, Arbiter.Core |
| JobWriteSource | |
| 1 (Type/Class) | Arbiter.Core.Codec |
| 2 (Data Constructor) | Arbiter.Core.Codec |
| joinColumns | Arbiter.Core.Codec |
| JsAttempts | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsGroupKey | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsInsertedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsLastAttemptedAt | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsNotVisibleUntil | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsParentId | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| JsPriority | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| keyCount | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| kindCounts | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| kindOf | Arbiter.Core.Job.Kind, Arbiter.Core.Job.Types, Arbiter.Core |
| kindsFor | Arbiter.Core.Job.Kind, Arbiter.Core.Job.Types, Arbiter.Core |
| labelArbiterThread | Arbiter.Core.Threads |
| LapsedOnly | Arbiter.Core.Operations |
| lastAttemptedAt | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| lastCheckedAt | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| lastError | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| lastFiredAt | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| lastHeartbeat | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| lastManualRunAt | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| lastRefill | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| leaf | Arbiter.Core.JobTree, Arbiter.Core |
| legacyEventStreamingTriggers | Arbiter.Core.Job.Schema |
| limitBy | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| limitByCase | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| listArchiveFiltered | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listArchiveFilteredSQL | Arbiter.Core.Sql.Archive |
| listArchiveJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listArchiveJobsByGroup | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listConcurrencyKeys | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| listConcurrencyKeysSQL | Arbiter.Core.Sql.Concurrency |
| listConcurrencyPolicies | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| listCronSchedules | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listCronSchedulesSQL | Arbiter.Core.Sql.Cron |
| listDLQFiltered | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listDLQFilteredOrdered | Arbiter.Core.Operations |
| listDLQFilteredSQL | Arbiter.Core.Sql.DLQ |
| listDLQJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listDLQJobsByParent | Arbiter.Core.Operations |
| ListenConn | |
| 1 (Type/Class) | Arbiter.Core.Listen, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Listen, Arbiter.Core |
| listenConsumeInput | Arbiter.Core.Listen, Arbiter.Core |
| Listener | Arbiter.Core.Listen, Arbiter.Core |
| listener | Arbiter.Core.Backend |
| listenEscapeIdentifier | Arbiter.Core.Listen, Arbiter.Core |
| listenExec | Arbiter.Core.Listen, Arbiter.Core |
| listenNotifies | Arbiter.Core.Listen, Arbiter.Core |
| listenSocket | Arbiter.Core.Listen, Arbiter.Core |
| listGroups | Arbiter.Core.Operations |
| listGroupsSQL | Arbiter.Core.Sql.Stats |
| listJobs | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listJobsByGroup | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listJobsByParent | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listJobsFiltered | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listJobsFilteredOrdered | Arbiter.Core.Operations |
| listJobsFilteredSQL | Arbiter.Core.Sql.Jobs |
| listJobsWithStatus | Arbiter.Core.Operations |
| listJobsWithStatusSQL | Arbiter.Core.Sql.Jobs |
| listQueues | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listQueuesSQL | Arbiter.Core.Sql.Queues |
| listRateLimitBuckets | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| listRateLimitBucketsSQL | Arbiter.Core.Sql.RateLimit |
| listRateLimitPolicies | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| listWorkers | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| listWorkersSQL | Arbiter.Core.Sql.Workers |
| Lit | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| Live | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| liveTup | Arbiter.Core.Health |
| localPoolState | Arbiter.Core.Backend |
| lockConcurrencyCountsSQL | Arbiter.Core.Sql.Concurrency |
| lockDeadConcurrencyKeysSQL | Arbiter.Core.Sql.Concurrency |
| lockDLQRetryGroupsSQL | Arbiter.Core.Sql.DLQ |
| lockDLQRetryParentSQL | Arbiter.Core.Sql.DLQ |
| lockedByIdsCte | Arbiter.Core.Sql.Tree |
| lockGroupKeyOnConflictSQL | Arbiter.Core.SqlLiterals |
| lockGroupKeysSQL | Arbiter.Core.Sql.Groups |
| lockGroupsSQL | Arbiter.Core.Sql.Groups |
| lockJobParents | Arbiter.Core.Operations |
| lockJobRootsAndParents | Arbiter.Core.Operations |
| lockJobTrees | Arbiter.Core.Operations |
| lockJobTreesFromRoot | Arbiter.Core.Operations |
| lockJobTreesFromRootSQL | Arbiter.Core.Sql.Tree |
| lockJobTreesSQL | Arbiter.Core.Sql.Tree |
| LocksHeld | Arbiter.Core.Operations |
| MainTable | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| maintenanceFunctionNames | Arbiter.Core.Job.Schema |
| mapPayload | Arbiter.Core.Job.Types, Arbiter.Core |
| markSpanError | Arbiter.Core.Trace |
| markWorkerShuttingDown | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| markWorkerShuttingDownSQL | Arbiter.Core.Sql.Workers |
| maxAttempts | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| maxIdentifierBytes | Arbiter.Core.SqlLiterals |
| maxInFlight | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| maxOutputHoles | Arbiter.Core.Sql.QQ |
| maxTokens | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| mergeRawChildResults | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| metadata | |
| 1 (Function) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| micros | Arbiter.Core.Threads, Arbiter.Core.Operations |
| microsPerSecond | Arbiter.Core.Threads |
| migrateGroupsReadyRankingSQL | Arbiter.Core.Job.Schema.Groups |
| migrateUngroupedReadySplitIndexesSQL | Arbiter.Core.Job.Schema |
| millisPerSecond | Arbiter.Core.Threads |
| minMaxAttempts | Arbiter.Core.Job.Types, Arbiter.Core |
| minMaxAttemptsSQL | Arbiter.Core.SqlLiterals |
| minTokens | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| mkJobStatements | Arbiter.Core.Operations |
| mkQuery | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| MonadArbiter | Arbiter.Core.MonadArbiter, Arbiter.Core |
| MoveIfExhausted | Arbiter.Core.Sql.DLQ |
| MoveNow | Arbiter.Core.Sql.DLQ |
| moveToDLQ | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| moveToDLQBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| moveToDLQBatchSQL | Arbiter.Core.Sql.DLQ |
| moveToDLQFields | Arbiter.Core.Operations |
| moveToDLQSQL | Arbiter.Core.Sql.DLQ |
| mwhen | Arbiter.Core.Sql.Query |
| nackJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| nackJobAfter | Arbiter.Core.HighLevel, Arbiter.Core |
| nackJobsBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| nackJobsBatchAfter | Arbiter.Core.HighLevel, Arbiter.Core |
| nackJobsBatchSQL | Arbiter.Core.Sql.Lifecycle |
| nackJobSQL | Arbiter.Core.Sql.Lifecycle |
| name | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| namedJobIds | Arbiter.Core.Exceptions |
| ncol | Arbiter.Core.Codec |
| newFailureGate | Arbiter.Core.FailureGate |
| newListener | Arbiter.Core.Listen, Arbiter.Core |
| noConcurrency | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| noLimit | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| noStagedCapacities | Arbiter.Core.Operations |
| Notification | |
| 1 (Type/Class) | Arbiter.Core.Listen |
| 2 (Data Constructor) | Arbiter.Core.Listen |
| notificationChannel | Arbiter.Core.Listen |
| notificationChannelForTable | Arbiter.Core.Job.Schema |
| notificationData | Arbiter.Core.Listen |
| notifyAdoptedObjectComment | Arbiter.Core.Job.Schema |
| notifyFunctionName | Arbiter.Core.Job.Schema |
| notifyObjectComment | Arbiter.Core.Job.Schema |
| notifyObjectCommentPrefix | Arbiter.Core.Job.Schema |
| notifyTriggerName | Arbiter.Core.Job.Schema |
| NotNull | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| notVisibleUntil | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| Nullable | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| NullCol | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| numBackends | Arbiter.Core.Health |
| ObservabilityHooks | |
| 1 (Type/Class) | Arbiter.Core.Job.Types, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.Types, Arbiter.Core |
| oldestInFlightAgeSeconds | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| oldestQueryAge | Arbiter.Core.Health |
| oldestReadyAgeSeconds | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| oldestTxnAge | Arbiter.Core.Health |
| onJobCancelled | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobClaimed | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobFailedAndMovedToDLQ | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobFailure | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobHeartbeat | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobRetry | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobSuccess | Arbiter.Core.Job.Types, Arbiter.Core |
| onJobUnavailable | Arbiter.Core.Job.Types, Arbiter.Core |
| orThrowInternal | Arbiter.Core.Exceptions, Arbiter.Core |
| orThrowParsing | Arbiter.Core.Exceptions, Arbiter.Core |
| overrideExpression | |
| 1 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| overrideInterval | |
| 1 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| 2 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| overrideLimit | |
| 1 (Function) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| 2 (Function) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| overrideMaxTokens | |
| 1 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| 2 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| overrideOverlap | |
| 1 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| overrideRefillAmount | |
| 1 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| 2 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| overrideTimezone | |
| 1 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| overviewQueue | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| overviewQueuePaused | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| overviewStats | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| overviewWorkersLive | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| overviewWorkersPaused | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| param | Arbiter.Core.Sql.Query |
| Params | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| ParamType | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| parentId | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| parentState | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| parr | Arbiter.Core.Codec |
| PArray | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| ParsingException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| passRepairFailed | Arbiter.Core.Operations |
| passResume | Arbiter.Core.Operations |
| passRewritten | Arbiter.Core.Operations |
| patchOptions | Arbiter.Core.Json |
| pauseChildren | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| pauseChildrenSQL | Arbiter.Core.Sql.Tree |
| paused | |
| 1 (Function) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Function) | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| pausedAt | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| pauseNotifyChannel | Arbiter.Core.Job.Schema |
| pauseNotifyChannelPrefix | Arbiter.Core.Job.Schema |
| payload | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| PayloadColumns | |
| 1 (Type/Class) | Arbiter.Core.Job.Types |
| 2 (Data Constructor) | Arbiter.Core.Job.Types |
| PayloadKeys | |
| 1 (Type/Class) | Arbiter.Core.Job.Types, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.Types, Arbiter.Core |
| payloadKeys | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| payloadWriteCodec | Arbiter.Core.Codec |
| pcConcurrencyKey | Arbiter.Core.Job.Types |
| pcConcurrencyPrefix | Arbiter.Core.Job.Types |
| pcKind | Arbiter.Core.Job.Types |
| pcRateLimitCost | Arbiter.Core.Job.Types |
| pcRateLimitKey | Arbiter.Core.Job.Types |
| pcRateLimitPrefix | Arbiter.Core.Job.Types |
| pendingCronRuns | Arbiter.Core.Operations |
| pendingCronRunsSQL | Arbiter.Core.Sql.Cron |
| PerBatch | Arbiter.Core.Trace |
| PerJob | Arbiter.Core.Trace |
| Permanent | Arbiter.Core.Exceptions, Arbiter.Core |
| persistParentState | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| persistParentStateSQL | Arbiter.Core.Sql.Tree |
| PgDbHealth | |
| 1 (Type/Class) | Arbiter.Core.Health |
| 2 (Data Constructor) | Arbiter.Core.Health |
| pgDbHealthSQL | Arbiter.Core.Sql.Health |
| PgTableHealth | |
| 1 (Type/Class) | Arbiter.Core.Health |
| 2 (Data Constructor) | Arbiter.Core.Health |
| pgTableHealthSQL | Arbiter.Core.Sql.Health |
| Piece | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| pinConnection | Arbiter.Core.Backend |
| pinned | Arbiter.Core.Backend |
| pnarr | Arbiter.Core.Codec |
| pnul | Arbiter.Core.Codec |
| PNullable | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| PNullArray | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| policyInterval | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| policyMax | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| policyPrefix | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| policyPrefixOf | Arbiter.Core.Admission, Arbiter.Concurrency, Arbiter.RateLimit |
| policyRefill | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| policyUpsertSQL | Arbiter.Core.Admission |
| PollDone | Arbiter.Core.Listen.Driver |
| Polling | Arbiter.Core.Listen.Driver |
| PollReading | Arbiter.Core.Listen.Driver |
| PollWriting | Arbiter.Core.Listen.Driver |
| PoolConfig | |
| 1 (Type/Class) | Arbiter.Core.PoolConfig, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.PoolConfig, Arbiter.Core |
| poolIdleTimeout | Arbiter.Core.PoolConfig, Arbiter.Core |
| poolListener | Arbiter.Core.Backend |
| poolSize | Arbiter.Core.PoolConfig, Arbiter.Core |
| PoolState | |
| 1 (Type/Class) | Arbiter.Core.Backend |
| 2 (Data Constructor) | Arbiter.Core.Backend |
| poolState | Arbiter.Core.Backend |
| poolStripes | Arbiter.Core.PoolConfig, Arbiter.Core |
| prefix | |
| 1 (Function) | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| 2 (Function) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| prefixedKeyParseJSON | Arbiter.Core.Admission |
| prefixedKeyText | Arbiter.Core.Admission |
| prefixedKeyToJSON | Arbiter.Core.Admission |
| Prim | Arbiter.Core.Selector |
| primaryKey | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| priority | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| promoteJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| promoteJobSQL | Arbiter.Core.Sql.Lifecycle |
| pruneConcurrencyKeys | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| pruneLockedConcurrencyKeysSQL | Arbiter.Core.Sql.Concurrency |
| pruneRateLimitBuckets | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| pruneRateLimitBucketsSQL | Arbiter.Core.Sql.RateLimit |
| PScalar | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| Published | Arbiter.Core.Operations |
| purgeArchives | Arbiter.Core.Operations |
| purgeArchiveSQL | Arbiter.Core.Sql.Archive |
| purgeDLQ | Arbiter.Core.Operations |
| pval | Arbiter.Core.Codec |
| qDecode | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| qParams | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| qPieces | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| qPositional | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| qSql | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| qualifiedName | Arbiter.Core.Job.Schema |
| Query | |
| 1 (Type/Class) | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| 2 (Data Constructor) | Arbiter.Core.Sql.Query, Arbiter.Core.MonadArbiter |
| queryAny | Arbiter.Core.MonadArbiter, Arbiter.Core |
| queryMaybe | Arbiter.Core.MonadArbiter, Arbiter.Core |
| Queue | Arbiter.Core.QueueRegistry, Arbiter.Core |
| queueDLQRetentionsSQL | Arbiter.Core.Sql.Queues |
| queueName | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| 3 (Function) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| 4 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| 5 (Function) | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| QueueOperation | Arbiter.Core.HighLevel, Arbiter.Core |
| QueueOverview | |
| 1 (Type/Class) | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| QueueRow | |
| 1 (Type/Class) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| queueRowCodec | Arbiter.Core.Codec |
| QueueSpec | Arbiter.Core.QueueRegistry, Arbiter.Core |
| QueueStats | |
| 1 (Type/Class) | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| queueStatusCounts | Arbiter.Core.Operations |
| queueTable | Arbiter.Core.HighLevel, Arbiter.Core |
| queueTableNames | Arbiter.Core.Job.Schema |
| QueueWithResult | Arbiter.Core.QueueRegistry, Arbiter.Core, Arbiter.Core |
| quoteIdentifier | Arbiter.Core.SqlLiterals |
| Ran | Arbiter.Core.Operations |
| rateLimitBucketCodec | Arbiter.Core.Codec |
| RateLimitBucketView | |
| 1 (Type/Class) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| 2 (Data Constructor) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| rateLimitCost | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| RateLimitFor | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| rateLimitFor | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| RateLimitKey | |
| 1 (Type/Class) | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| 2 (Data Constructor) | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| rateLimitKey | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| rateLimitKeyText | Arbiter.Core.RateLimit.Spec |
| rateLimitPoliciesSQL | Arbiter.Core.Sql.RateLimit |
| RateLimitPolicy | |
| 1 (Type/Class) | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| 2 (Data Constructor) | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| rateLimitPolicyExists | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| rateLimitPolicyExistsSQL | Arbiter.Core.Sql.RateLimit |
| RateLimitPolicyUpdate | |
| 1 (Type/Class) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| 2 (Data Constructor) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| RateLimitPolicyView | |
| 1 (Type/Class) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| 2 (Data Constructor) | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| rateLimitPolicyViewCodec | Arbiter.Core.Codec |
| rateLimitPrefix | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| raw | Arbiter.Core.Sql.Query |
| rawRows | Arbiter.Core.Sql.Query |
| readChildResultsRaw | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| readChildResultsSQL | Arbiter.Core.Sql.Tree |
| Ready | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| readyJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| reconcileAndPruneConcurrency | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| reconcileConcurrencyCounts | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| reconcileConcurrencyCountsIfStale | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| reconcileConcurrencyCountsSQL | Arbiter.Core.Sql.Concurrency |
| recordJobCancelled | Arbiter.Core.Trace |
| recordJobFailure | Arbiter.Core.Trace |
| reEnqueueFromArchive | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| reEnqueueFromArchiveSQL | Arbiter.Core.Sql.Archive |
| reEnqueueFromArchiveWithPayload | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| refilledBucketTokens | Arbiter.Core.Sql.RateLimit |
| refilledExpr | Arbiter.Core.Sql.RateLimit |
| refreshAllGroups | Arbiter.Core.Operations |
| refreshAllGroupsFully | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| refreshGroupsForQueue | Arbiter.Core.Operations |
| refreshGroupsSQL | Arbiter.Core.Sql.Groups |
| registerQueuesSQL | Arbiter.Core.Queues |
| registerWorker | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| RegistryAdmissionPolicies | Arbiter.Core.Job.Types, Arbiter.Core.HighLevel, Arbiter.Core |
| RegistryConcurrencyPolicies | Arbiter.Core.Concurrency.Spec, Arbiter.Concurrency |
| registryConcurrencyPolicies | Arbiter.Core.Concurrency.Spec |
| registryConcurrencyTables | Arbiter.Core.Concurrency.Spec |
| RegistryOf | Arbiter.Core.MonadArbiter, Arbiter.Core, Arbiter.Core |
| RegistryPolicies | Arbiter.Core.Admission |
| registryPolicies | Arbiter.Core.Admission |
| registryPolicyTables | Arbiter.Core.Admission |
| registryQueueKinds | Arbiter.Core.QueueRegistry, Arbiter.Core |
| RegistryRateLimitPolicies | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| registryRateLimitPolicies | Arbiter.Core.RateLimit.Spec |
| registryRateLimitTables | Arbiter.Core.RateLimit.Spec |
| registryTableNames | Arbiter.Core.QueueRegistry, Arbiter.Core |
| registryTablePolicies | Arbiter.Core.Admission |
| RegistryTables | Arbiter.Core.QueueRegistry, Arbiter.Core |
| RejectedRow | Arbiter.Core.Operations |
| releaseGateSQL | Arbiter.Core.Sql.Gates |
| ReplaceDuplicate | Arbiter.Core.Job.Dedup, Arbiter.Core.Job.Types, Arbiter.Core |
| requestCronRun | Arbiter.Core.Operations |
| requestCronRunSQL | Arbiter.Core.Sql.Cron |
| requeuedCols | Arbiter.Core.Sql.Jobs |
| requeuedValsEditing | Arbiter.Core.Sql.Jobs |
| rescheduleJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| rescheduleJobSQL | Arbiter.Core.Sql.Lifecycle |
| resetRateLimitBuckets | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| resetRateLimitBucketsSQL | Arbiter.Core.Sql.RateLimit |
| resolveTracer | Arbiter.Core.Trace |
| ResultFor | Arbiter.Core.QueueRegistry, Arbiter.Core |
| ResultOf | Arbiter.Core.MonadArbiter, Arbiter.Core |
| resumeChildren | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| resumeChildrenSQL | Arbiter.Core.Sql.Tree |
| resumeJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| resumeJobSQL | Arbiter.Core.Sql.Tree |
| Retryable | Arbiter.Core.Exceptions, Arbiter.Core |
| retryDLQFiltered | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| retryFromDLQ | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| retryFromDLQBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| retryFromDLQSQL | Arbiter.Core.Sql.DLQ |
| retryFromDLQWithPayload | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| rlkPrefix | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| rlkSuffix | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| rollup | Arbiter.Core.JobTree, Arbiter.Core |
| rollupIdsSQL | Arbiter.Core.Sql.Tree |
| RowCodec | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| RowEdit | |
| 1 (Type/Class) | Arbiter.Core.Sql.Insert |
| 2 (Data Constructor) | Arbiter.Core.Sql.Insert |
| rowEdit | Arbiter.Core.Sql.Insert |
| rows | Arbiter.Core.Sql.Query |
| runCodec | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| runDb | Arbiter.Core.Backend |
| runGated | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| runGatedBounded | Arbiter.Core.Operations |
| runGatedShared | Arbiter.Core.Operations |
| runGatedState | Arbiter.Core.Operations |
| runGatedStateBounded | Arbiter.Core.Operations |
| runHandlerWithConnection | Arbiter.Core.MonadArbiter, Arbiter.Core |
| RunReqDisabled | Arbiter.Core.Operations |
| RunReqNotFound | Arbiter.Core.Operations |
| RunReqPending | Arbiter.Core.Operations |
| RunReqStamped | Arbiter.Core.Operations |
| runRequestedAt | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| RunRequestOutcome | Arbiter.Core.Operations |
| runSelector | Arbiter.Core.Selector |
| Scheduled | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| scheduledJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| schema | Arbiter.Core.Backend |
| SchemaName | Arbiter.Core.Job.Schema, Arbiter.Core |
| schemaQueues | Arbiter.Core.Operations |
| selectBy | Arbiter.Core.Admission |
| selectByCase | Arbiter.Core.Selector |
| selectCancelledReapableJobsSQL | Arbiter.Core.Sql.Tree |
| selectExhaustedJobsSQL | Arbiter.Core.Sql.DLQ |
| selectExpiredDLQSQL | Arbiter.Core.Sql.DLQ |
| selectNone | Arbiter.Core.Admission |
| Selector | Arbiter.Core.Selector, Arbiter.Concurrency, Arbiter.RateLimit |
| sepBy | Arbiter.Core.Sql.Query |
| seqScan | Arbiter.Core.Health |
| setArchiveFor | Arbiter.Core.Job.Types, Arbiter.Core |
| setConcurrencyLimit | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| setDedupKey | Arbiter.Core.Job.Types, Arbiter.Core |
| setGateMetadataSQL | Arbiter.Core.Sql.Gates |
| setGroupKey | Arbiter.Core.Job.Types, Arbiter.Core |
| setLocalStatementTimeout | Arbiter.Core.Operations |
| setMaxAttempts | Arbiter.Core.Job.Types, Arbiter.Core |
| setMaxAttemptsDefaultSQL | Arbiter.Core.Job.Schema |
| setNotVisibleUntil | Arbiter.Core.Job.Types, Arbiter.Core |
| setPayload | Arbiter.Core.Job.Types, Arbiter.Core |
| setPriority | Arbiter.Core.Job.Types, Arbiter.Core |
| setQueueDLQRetention | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| setQueueDLQRetentionSQL | Arbiter.Core.Sql.Queues |
| setQueuePaused | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| setQueuePausedSQL | Arbiter.Core.Sql.Queues |
| setRateLimit | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| settleGroupLocksCte | Arbiter.Core.Sql.Groups |
| setTraceContext | Arbiter.Core.Job.Types, Arbiter.Core |
| SetVisibilityResult | Arbiter.Core.HighLevel, Arbiter.Core |
| setVisibilityTimeout | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| setVisibilityTimeoutBatch | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| setVisibilityTimeoutBatchSQL | Arbiter.Core.Sql.Lifecycle |
| setVisibilityTimeoutSQL | Arbiter.Core.Sql.Lifecycle |
| setWorkerPaused | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| setWorkerPausedSQL | Arbiter.Core.Sql.Workers |
| Shared | Arbiter.Core.Operations |
| sharedArbiterTables | Arbiter.Core.SchemaTables |
| sharedTable | Arbiter.Core.SqlLiterals |
| showText | Arbiter.Core.Enum |
| shuttingDown | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| singleJobBatchSize | Arbiter.Core.Operations |
| smartAckJobsBatchSQL | Arbiter.Core.Sql.Lifecycle |
| smartAckJobSQL | Arbiter.Core.Sql.Lifecycle |
| SomeParam | |
| 1 (Type/Class) | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| 2 (Data Constructor) | Arbiter.Core.Codec, Arbiter.Core.MonadArbiter |
| SortAsc | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| SortDesc | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| SortDir | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| sortDirName | Arbiter.Core.Sql.Jobs, Arbiter.Core.Operations |
| sourceColumns | Arbiter.Core.Codec |
| sourceEncoded | Arbiter.Core.Codec |
| sourceJob | Arbiter.Core.Codec |
| sourceParentId | Arbiter.Core.Codec |
| sourceParentState | Arbiter.Core.Codec |
| sourceSuspended | Arbiter.Core.Codec |
| spawnChildren | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| spawnedAlreadySQL | Arbiter.Core.Sql.Tree |
| SpecForPayload | Arbiter.Core.QueueRegistry, Arbiter.Core |
| SpecName | Arbiter.Core.QueueRegistry, Arbiter.Core |
| SpecPayload | Arbiter.Core.QueueRegistry, Arbiter.Core |
| SpecResult | Arbiter.Core.QueueRegistry, Arbiter.Core |
| splitPrefixedSuffix | Arbiter.Core.Admission |
| sql | Arbiter.Core.Sql.QQ |
| Stale | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| staleThresholdSecs | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| stampTraceContext | Arbiter.Core.Trace |
| startedAt | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| StartTime | Arbiter.Core.Job.Types, Arbiter.Core |
| statementsAck | Arbiter.Core.Operations |
| statementTriggerSQL | Arbiter.Core.Job.Schema |
| statsRowCodec | Arbiter.Core.Operations |
| stmt | Arbiter.Core.Sql.QQ |
| Stored | |
| 1 (Type/Class) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core.MonadArbiter, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.MonadArbiter |
| storedBytes | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core.MonadArbiter, Arbiter.Core |
| Suspended | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| suspended | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| suspendedJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| suspendJob | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| suspendJobSQL | Arbiter.Core.Sql.Tree |
| sweepCancelledJobs | Arbiter.Core.Operations |
| sweepExhaustedJobs | Arbiter.Core.Operations |
| sweepStaleWorkers | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| table | Arbiter.Core.Health |
| TableForPayload | Arbiter.Core.QueueRegistry, Arbiter.Core |
| TableName | Arbiter.Core.Job.Schema, Arbiter.Core |
| TakeLocks | Arbiter.Core.Operations |
| textLiteral | Arbiter.Core.SqlLiterals |
| Throttled | Arbiter.Core.Job.Status, Arbiter.Core.Job.Types, Arbiter.Core |
| throttledCount | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| throttledJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| throttledPredicateSQL | Arbiter.Core.Sql.Jobs |
| throttledQueues | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| throwBranchCancel | Arbiter.Core.Exceptions, Arbiter.Core |
| throwInternal | Arbiter.Core.Exceptions |
| throwJobGone | Arbiter.Core.Exceptions |
| throwJobGoneIds | Arbiter.Core.Exceptions |
| throwNack | Arbiter.Core.Exceptions, Arbiter.Core |
| throwNackAfter | Arbiter.Core.Exceptions, Arbiter.Core |
| throwParsing | Arbiter.Core.Exceptions |
| throwPermanent | Arbiter.Core.Exceptions, Arbiter.Core |
| throwRetryable | Arbiter.Core.Exceptions, Arbiter.Core |
| throwRetryableAfter | Arbiter.Core.Exceptions, Arbiter.Core |
| throwScopedFailure | Arbiter.Core.Exceptions |
| throwTreeCancel | Arbiter.Core.Exceptions, Arbiter.Core |
| toConcurrencyKey | Arbiter.Core.Concurrency.Spec |
| toConsumeShape | Arbiter.Core.Trace |
| ToFragment | Arbiter.Core.Sql.Query |
| toFragment | Arbiter.Core.Sql.Query |
| tokenBucket | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| tokens | Arbiter.Core.RateLimit.Stats, Arbiter.RateLimit |
| toRateLimitKey | Arbiter.Core.RateLimit.Spec |
| toStored | Arbiter.Core.Job.Types, Arbiter.Core |
| totalBytes | Arbiter.Core.Health |
| totalInFlight | Arbiter.Core.Concurrency.Stats, Arbiter.Concurrency |
| totalJobs | Arbiter.Core.Operations, Arbiter.Core.HighLevel, Arbiter.Core |
| toTraceContext | Arbiter.Core.Job.TraceContext, Arbiter.Core.Job.Types, Arbiter.Core |
| touchCronChecked | Arbiter.Core.Operations |
| touchCronCheckedSQL | Arbiter.Core.Sql.Cron |
| touchCronManualRun | Arbiter.Core.Operations |
| touchCronManualRunSQL | Arbiter.Core.Sql.Cron |
| TraceContext | |
| 1 (Type/Class) | Arbiter.Core.Job.TraceContext, Arbiter.Core.Job.Types, Arbiter.Core.Trace, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Job.TraceContext, Arbiter.Core.Job.Types, Arbiter.Core.Trace, Arbiter.Core |
| traceContext | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| traceparent | Arbiter.Core.Job.TraceContext, Arbiter.Core.Job.Types, Arbiter.Core.Trace, Arbiter.Core |
| Tracer | Arbiter.Core.Trace |
| TraceStamp | Arbiter.Core.Operations |
| traceStamp | Arbiter.Core.Operations |
| tracestate | Arbiter.Core.Job.TraceContext, Arbiter.Core.Job.Types, Arbiter.Core.Trace, Arbiter.Core |
| TreeCancel | Arbiter.Core.Exceptions, Arbiter.Core |
| TreeCancelException | |
| 1 (Type/Class) | Arbiter.Core.Exceptions, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Exceptions, Arbiter.Core |
| TreeLocks | Arbiter.Core.Operations |
| treeRollupIdsSQL | Arbiter.Core.Sql.Tree |
| TreesLocked | Arbiter.Core.Operations |
| tryAcquireCronLeader | Arbiter.Core.Operations |
| tryAcquireCronLeaderSQL | Arbiter.Core.Sql.Cron |
| tryClaimGateSQL | Arbiter.Core.Sql.Gates |
| tryFireCronGate | Arbiter.Core.Operations |
| tryFireCronGateSQL | Arbiter.Core.Sql.Cron |
| tryLockDeadConcurrencyAdvisorySQL | Arbiter.Core.Sql.Concurrency |
| tryWakeAncestorSQL | Arbiter.Core.Sql.Tree |
| typedArchiveRow | Arbiter.Core.Operations |
| typedDLQRow | Arbiter.Core.Operations |
| typedRow | Arbiter.Core.Operations |
| unDb | Arbiter.Core.Backend |
| unionAllOverQueueTables | Arbiter.Core.Sql.Jobs |
| Unlogged | Arbiter.Core.RateLimit.Spec, Arbiter.RateLimit |
| Unreadable | Arbiter.Core.Operations |
| updateArchiveResult | Arbiter.Core.Operations |
| updateArchiveResultsBatch | Arbiter.Core.Operations |
| updateArchiveResultsBatchSQL | Arbiter.Core.Sql.Archive |
| updateArchiveResultSQL | Arbiter.Core.Sql.Archive |
| updateConcurrencyPolicyOverrides | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Concurrency, Arbiter.Core |
| updateConcurrencyPolicyOverridesSQL | Arbiter.Core.Sql.Concurrency |
| updateCronSchedule | Arbiter.Core.Operations |
| updateCronScheduleSQL | Arbiter.Core.Sql.Cron |
| updateCronScheduleUnchecked | Arbiter.Core.HighLevel, Arbiter.Core |
| updatedAt | |
| 1 (Function) | Arbiter.Core.Job.Types.Internal |
| 2 (Function) | Arbiter.Core.Job.Types.Internal, Arbiter.Core.Job.Types, Arbiter.Core |
| 3 (Function) | Arbiter.Core.Queues, Arbiter.Core.HighLevel, Arbiter.Core |
| 4 (Function) | Arbiter.Core.CronSchedule, Arbiter.Core.HighLevel, Arbiter.Core |
| updateJobForRetry | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core |
| updateJobForRetrySQL | Arbiter.Core.Sql.Lifecycle |
| updateRateLimitPolicyOverrides | |
| 1 (Function) | Arbiter.Core.Operations |
| 2 (Function) | Arbiter.Core.HighLevel, Arbiter.Core, Arbiter.RateLimit |
| updateRateLimitPolicyOverridesSQL | Arbiter.Core.Sql.RateLimit |
| upsertConcurrencyPolicyRowSQL | Arbiter.Core.Concurrency.Schema |
| upsertCronDefault | Arbiter.Core.Operations |
| upsertCronDefaultSQL | Arbiter.Core.Sql.Cron |
| upsertRateLimitPolicyRowSQL | Arbiter.Core.RateLimit.Schema |
| upsertWorkerSQL | Arbiter.Core.Sql.Workers |
| useDedicatedListener | Arbiter.Core.Backend |
| usePolicy | Arbiter.Core.Selector |
| usesAnyPolicy | Arbiter.Core.Selector |
| vacuumAge | Arbiter.Core.Health |
| VisibilityExtended | Arbiter.Core.HighLevel, Arbiter.Core |
| VisibilityUnchanged | Arbiter.Core.HighLevel, Arbiter.Core |
| VisibilityUpdateInfo | |
| 1 (Type/Class) | Arbiter.Core.Operations |
| 2 (Data Constructor) | Arbiter.Core.Operations |
| vuiCancelRequested | Arbiter.Core.Operations |
| vuiClaimedBy | Arbiter.Core.Operations |
| vuiCurrentDbClaimSeq | Arbiter.Core.Operations |
| vuiJobId | Arbiter.Core.Operations |
| vuiSuspended | Arbiter.Core.Operations |
| vuiWasHeartbeated | Arbiter.Core.Operations |
| wakeParentCte | Arbiter.Core.Sql.Tree |
| wakeThrottledJobs | Arbiter.Core.Operations |
| wakeThrottledJobsForKey | Arbiter.Core.Operations |
| wakeThrottledJobsForKeySQL | Arbiter.Core.Sql.RateLimit |
| wakeThrottledJobsSQL | Arbiter.Core.Sql.RateLimit |
| withChannels | Arbiter.Core.Listen, Arbiter.Core |
| withConn | Arbiter.Core.Backend |
| withConsumeSpan | Arbiter.Core.Trace |
| withDbTransaction | Arbiter.Core.MonadArbiter, Arbiter.Core |
| withDriverListenConn | Arbiter.Core.Listen.Driver |
| withJobParent | Arbiter.Core.Trace |
| withListenConn | Arbiter.Core.Backend |
| withPublishSpan | Arbiter.Core.Trace |
| withSavepointTransaction | Arbiter.Core.Backend |
| workerColumnList | Arbiter.Core.Sql.Workers |
| workerCount | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| WorkerHealth | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| workerHealthFromText | Arbiter.Core.Worker, Arbiter.Core |
| workerHealthToText | Arbiter.Core.Worker, Arbiter.Core |
| workerId | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| workerRegistered | Arbiter.Core.Operations |
| workerRegisteredSQL | Arbiter.Core.Sql.Workers |
| WorkerRow | |
| 1 (Type/Class) | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| 2 (Data Constructor) | Arbiter.Core.Worker, Arbiter.Core.HighLevel, Arbiter.Core |
| workerRowWithHealthCodec | Arbiter.Core.Codec |
| workerStaleSQL | Arbiter.Core.Sql.Workers |
| writeColumnNames | Arbiter.Core.Codec |
| xidAge | Arbiter.Core.Health |