import type { BrokerLogger } from "./logger.js"; import type { EmitOutcome, RuntimeEndpointPort } from "./runtime-endpoint-port.js"; import type { UndispatchedChangedEvent } from "./undispatched-changed-event-types.js"; export declare const DEFAULT_EMITTER_CAPACITY = 1024; export declare const DEFAULT_EMITTER_BACKOFF_INITIAL_MS = 500; export declare const DEFAULT_EMITTER_BACKOFF_MAX_MS = 30000; export declare const DEFAULT_EMITTER_MAX_RETRIES = 5; export interface UndispatchedChangedEmitterOptions { capacity?: number; backoffInitialMs?: number; backoffMaxMs?: number; maxRetries?: number; } export interface UndispatchedChangedEmitter { enqueue(event: UndispatchedChangedEvent): boolean; size(): number; capacity(): number; shutdown(): Promise; } export declare function createUndispatchedChangedEmitter(post: (event: UndispatchedChangedEvent) => Promise, logger: BrokerLogger, opts?: UndispatchedChangedEmitterOptions): UndispatchedChangedEmitter; export declare function postUndispatchedChangedViaPort(apiPort: RuntimeEndpointPort): (event: UndispatchedChangedEvent) => Promise; //# sourceMappingURL=undispatched-emitter.d.ts.map