class

JoobQ::Delivery::Migration

Inherits Reference < Object

Constants

RELEASE = "if redis.call('GET', KEYS[1]) == ARGV[1] then return redis.call('DEL', KEYS[1]) end return 0"

Constructors

new(ledger : Ledger, redis : Redis::PooledClient, queue : String, owner : String)
Source

Instance methods

activate(report : Report) : Nil

Explicit cutover only after operators verify the report and backup. Normal restart of the migrator cannot accidentally unpause a partially imported set.

Source
run(quiescent : Bool = false) : Report

Caller must stop old producers/workers first. Originals are retained. The second inventory detects concurrent source changes and leaves ingress gated.

Source

Nested types