Queue

Topics

Instance Properties

• var configuration: QueuesConfiguration
  The configuration for the queue
• var context: QueueContext
  The job context
• var eventLoop: any EventLoop
  The EventLoop for a job queue
• var key: String
  The key name of the queue
• var logger: Logger
  A logger
• var queueName: QueueName
  The queue’s name
• var worker: QueueWorker

Instance Methods

• func clear(JobIdentifier) -> EventLoopFuture<Void>
  Removes a job from the queue
• func dispatch(_:_:maxRetryCount:delayUntil:id:)
  Dispatch a job into the queue for processing
• func get(JobIdentifier) -> EventLoopFuture<JobData>
  Gets the next job to be run
• func pop() -> EventLoopFuture<JobIdentifier?>
  Pops the next job in the queue
• func push(JobIdentifier) -> EventLoopFuture<Void>
  Pushes the next job into a queue
• func set(JobIdentifier, to: JobData) -> EventLoopFuture<Void>
  Sets a job that should be run in the future