Interface RunCoordinator

src/coordinator/run-coordinator.ts:9–22

 * across a fleet (e.g. a Redis lock), provide one via `setRunCoordinator`.
 */
export interface RunCoordinator {
  /**
   * Return `true` if THIS instance should run the fire identified by `key`,
   * `false` to skip it (another instance handles it). Throw to fail closed
   * (the run is skipped). `ttlMs` is a safety lease hint for lease-based
   * coordinators (a Redis lock uses it; config-based ones ignore it).
   */
  shouldRun(key: string, ttlMs: number): boolean | Promise<boolean>;
  /**
   * Called after the run completes (success or failure); e.g. release a lock.
   * Config-based coordinators leave it unimplemented.
   */
  onComplete?(key: string): void | Promise<void>;
}

/** Why a scheduled execution was skipped (carried on `execution:skipped`). */
export type SkipReason = 'not-elected' | 'coordinator-error';