import type { RuntimeEventBus } from '../events/index.js'; import type { EmitterContext } from './index.js'; /** Emit TRANSPORT_INITIALIZING when the transport layer starts. */ export declare function emitTransportInitializing(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; protocol: string; }): void; /** Emit TRANSPORT_AUTHENTICATING when transport auth is in progress. */ export declare function emitTransportAuthenticating(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; }): void; /** Emit TRANSPORT_CONNECTED when the connection is ready. */ export declare function emitTransportConnected(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; endpoint: string; }): void; /** Emit TRANSPORT_SYNCING during state synchronisation. */ export declare function emitTransportSyncing(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; }): void; /** Emit TRANSPORT_DEGRADED during reduced-reliability operation. */ export declare function emitTransportDegraded(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; reason: string; }): void; /** Emit TRANSPORT_RECONNECTING when retrying after failure. */ export declare function emitTransportReconnecting(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; attempt: number; maxAttempts: number; }): void; /** Emit TRANSPORT_DISCONNECTED when the connection closes. */ export declare function emitTransportDisconnected(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; reason?: string; willRetry: boolean; }): void; /** Emit TRANSPORT_TERMINAL_FAILURE on unrecoverable failure. */ export declare function emitTransportTerminalFailure(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; error: string; }): void; /** Emit TRANSPORT_RETRY_SCHEDULED when a retry is queued with backoff. */ export declare function emitTransportRetryScheduled(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; attempt: number; maxAttempts: number; backoffMs: number; reason: string; }): void; /** Emit TRANSPORT_RETRY_EXECUTED when a retry attempt is fired. */ export declare function emitTransportRetryExecuted(bus: RuntimeEventBus, ctx: EmitterContext, data: { transportId: string; attempt: number; maxAttempts: number; }): void; /** Emit STREAM_SUBSCRIBER_CONNECTED when an SSE subscriber connects. */ export declare function emitStreamSubscriberConnected(bus: RuntimeEventBus, ctx: EmitterContext, data: { streamId: string; subscriberId: string; streamType: string; }): void; /** Emit STREAM_SUBSCRIBER_DISCONNECTED when an SSE subscriber disconnects. */ export declare function emitStreamSubscriberDisconnected(bus: RuntimeEventBus, ctx: EmitterContext, data: { streamId: string; subscriberId: string; streamType: string; reason?: string; }): void; //# sourceMappingURL=transport.d.ts.map