lightspeed/integration/jobs
Background-job integration patterns for ecosystem compatibility (M26).
Types
One job integration pattern.
pub type Pattern {
Pattern(
name: String,
backend: QueueBackend,
retry_policy: RetryPolicy,
tenant_partitioned: Bool,
dead_letter_enabled: Bool,
)
}
Constructors
-
Pattern( name: String, backend: QueueBackend, retry_policy: RetryPolicy, tenant_partitioned: Bool, dead_letter_enabled: Bool, )
Queue backend profile.
pub type QueueBackend {
GleamWorkerPool(pool_size: Int)
ObanBridge(module: String)
MixedQueue(primary: String, fallback: String)
}
Constructors
-
GleamWorkerPool(pool_size: Int) -
ObanBridge(module: String) -
MixedQueue(primary: String, fallback: String)
Retry/timeout policy for one job class.
pub type RetryPolicy {
RetryPolicy(
max_attempts: Int,
base_backoff_ms: Int,
timeout_ms: Int,
)
}
Constructors
-
RetryPolicy( max_attempts: Int, base_backoff_ms: Int, timeout_ms: Int, )