import type { Collector, TelescopeStorage } from '../types.js'; /** * Subscribes to `@rudderjs/queue/observers` and records one entry per * lifecycle transition. Replaces the legacy `dispatch()` monkey-patch * which only fired in the dispatching process — under BullMQ, worker-side * completion and failure events were never recorded. */ export declare class JobCollector implements Collector { private readonly storage; readonly name = "Job Collector"; readonly type: "job"; private unsubscribe; constructor(storage: TelescopeStorage); register(): Promise; } //# sourceMappingURL=job.d.ts.map