Job

Topics

Associated Types

• associatedtype Payload : Sendable
  The data associated with a job

Instance Methods

• func dequeue(QueueContext, Self.Payload) -> EventLoopFuture<Void>
  Called when it’s this Job’s turn to be dequeued.
• func error(QueueContext, any Error, Self.Payload) -> EventLoopFuture<Void>
  Called when there is an error at any stage of the Job’s execution.
• func nextRetryIn(attempt: Int) -> Int
  Called when there was an error and the job will be retried.

Type Methods

• static func parsePayload([UInt8]) throws -> Self.Payload
  Deserialize an array of bytes into a typed payload. When Payload is Codable, this method will default to decoding from JSON.
• static func serializePayload(Self.Payload) throws -> [UInt8]
  Serialize a typed payload to an array of bytes. When Payload is Codable, this method will default to encoding to JSON.