List of all items
Structs
- AdmissionExplain
- AdmissionUnit
- AdmitRequest
- AllErrorsAreFailures
- BulkRequest
- Caps
- Checkpoint
- Claim
- ConcurrencyLimitConfig
- Envelope
- HistoryBucket
- JobFilter
- JobOutput
- JobPage
- JobProgress
- JobResult
- JobSummary
- LeaseRef
- NoopTelemetry
- OperationStatus
- PartitionState
- ProgressUpdate
- QuarantineEntry
- QueueStats
- QuietGroupMetrics
- RateClassConfig
- RateClassState
- Reclaimed
- Schedule
- ScheduleEvent
- StateCounts
- TaskOptions
- TraceContext
- TransitionCtx
- WorkerMeta
Enums
- BlockedBy
- CodecError
- Event
- LifecycleEvent
- MissedPolicy
- Outcome
- Resume
- SaturationStrategy
- ScheduleEventOutcome
- State
- StoreError
Traits
- CheckpointInspect
- Clock
- IdGen
- Inspect
- IsFailure
- Notifying
- OutputInspect
- OutputStore
- ProgressInspect
- ProgressStore
- ResultInspect
- ResultStore
- Store
- Task
- Telemetry
- Transactional
- TxHandle
Functions
- age_ms
- bulk_action_states
- canonical_tags
- check_kind_collisions
- effective_max_attempts
- effective_schema_version
- effective_unique_key
- effective_weight
- enqueue_queue
- evaluate_admission
- fingerprint
- format_generated_id
- group_admission_claims
- lifecycle_transition
- noisy_partition_keys
- normalize_admit_request
- parse_traceparent
- same_job_content
- time_to_drain_ms
- trace_context
- transition
- valid_worker_command
- validate_ack_request
- validate_concurrency_limit
- validate_enqueue
- validate_kind
- validate_opaque_value
- validate_progress
- validate_rate_class_config
- validate_schedule_event_limit
Type Aliases
Constants
- MAX_ENQUEUE_BATCH_SIZE
- MAX_ENQUEUE_BYTES
- MAX_JOB_HEADERS_BYTES
- MAX_JOB_HEADER_COUNT
- MAX_JOB_IDENTIFIER_LEN
- MAX_JOB_PAYLOAD_BYTES
- MAX_OPAQUE_BYTES
- MAX_OPAQUE_SCHEMA_VERSION
- MAX_PROGRESS_MESSAGE_BYTES
- MAX_PROGRESS_VALUE
- MAX_UNIQUE_KEY_BYTES
- SCHEDULE_EVENT_LIMIT
- TRACEPARENT
- TRACESTATE
- UNIQUE_REPLACE_ALL
- UNIQUE_REPLACE_MAX_ATTEMPTS
- UNIQUE_REPLACE_PAYLOAD
- UNIQUE_REPLACE_PRIORITY
- UNIQUE_REPLACE_SCHEDULED_AT