class

Kiq::BatchCoordinationServerMiddleware

Inherits Kiq::Middleware::ServerMiddleware < Reference < Object

Constants

MAX_WAIT = 30

POLL_INTERVAL = 0.1

STABILITY_WINDOW = 0.5

Instance methods

call(job : Kiq::AnyJob, msg : Msg, queue : String, & : -> Nil) : Nil