Expand description
Job queue wire types (job-queue).
Structs§
- Queue
AckBatch Reply - Response to
QueueAckBatchRequest. - Queue
AckBatch Request - Acknowledge many leased jobs in one leader transaction
(
POST /raft/v1/queue/ack-batch). - Queue
AckReply - Response to
QueueAckRequest. - Queue
AckRequest - Acknowledge successful processing (
POST /raft/v1/queue/ack). - Queue
Batch Enqueue Job - One job in a batch enqueue (
POST /raft/v1/queue/enqueue-batch). - Queue
Enqueue Batch Reply - Response to
QueueEnqueueBatchRequest. - Queue
Enqueue Batch Request - Enqueue many jobs in one leader transaction (
POST /raft/v1/queue/enqueue-batch). - Queue
Enqueue Reply - Response to
QueueEnqueueRequest. - Queue
Enqueue Request - Enqueue a job on stream
stream(POST /raft/v1/queue/enqueue). - Queue
JobStatus Reply - Metadata for a single job (
POST /raft/v1/queue/job-status). - Queue
JobStatus Request - Lookup job metadata by id (
POST /raft/v1/queue/job-status). - Queue
Lease Reply - Response to
QueueLeaseRequest. - Queue
Lease Request - Lease jobs for a worker (
POST /raft/v1/queue/lease). - Queue
Leased JobWire - One job returned under lease on the wire.
- Queue
Metrics Reply - Depth and age gauges for autoscale / observability.
- Queue
Metrics Request - Read queue depth gauges (
POST /raft/v1/queue/metrics). - Queue
Nack Reply - Response to
QueueNackRequest. - Queue
Nack Request - Return a leased job to pending immediately (
POST /raft/v1/queue/nack). - Queue
Replicate Reply - Response to
QueueReplicateRequest. - Queue
Replicate Request - Batch of replication ops from the queue leader (
POST /raft/v1/queue/replicate). - Queue
Requeue Dead Letter Reply - Response to
QueueRequeueDeadLetterRequest. - Queue
Requeue Dead Letter Request - Requeue a dead-letter job for another delivery attempt
(
POST /raft/v1/queue/requeue-dead-letter). - Recurring
Schedule Wire - Cron-driven recurring job registered on a queue stream.
Enums§
- Queue
JobLifecycle Wire - Job lifecycle returned by
QueueJobStatusReply. - Queue
Replicate Op - Idempotent state transition replicated from the queue leader to every voter
(
POST /raft/v1/queue/replicate).