import type { BrokerLogger } from "./logger.js"; import type { EmitOutcome, RuntimeEndpointPort } from "./runtime-endpoint-port.js"; import type { RuntimeInboundRoutedEvent } from "./runtime-inbound-routed-event-types.js"; export declare const DEFAULT_INBOUND_ROUTED_EMITTER_CAPACITY = 1024; export declare const DEFAULT_INBOUND_ROUTED_EMITTER_BACKOFF_INITIAL_MS = 500; export declare const DEFAULT_INBOUND_ROUTED_EMITTER_BACKOFF_MAX_MS = 30000; export declare const DEFAULT_INBOUND_ROUTED_EMITTER_MAX_RETRIES = 5; export interface RuntimeInboundRoutedEmitterOptions { capacity?: number; backoffInitialMs?: number; backoffMaxMs?: number; maxRetries?: number; } export interface RuntimeInboundRoutedEmitter { enqueue(event: RuntimeInboundRoutedEvent, opts?: { onSuccess?: () => void; }): boolean; size(): number; capacity(): number; shutdown(): Promise; } export declare function createRuntimeInboundRoutedEmitter(post: (event: RuntimeInboundRoutedEvent) => Promise, logger: BrokerLogger, opts?: RuntimeInboundRoutedEmitterOptions): RuntimeInboundRoutedEmitter; export declare function postRuntimeInboundRoutedViaPort(apiPort: RuntimeEndpointPort): (event: RuntimeInboundRoutedEvent) => Promise; //# sourceMappingURL=runtime-inbound-routed-emitter.d.ts.map