/**
 * EventBus — warstwa intencji / orkiestracji.
 *
 * "Co się stało" (w przeciwieństwie do DataBus, który zajmuje się "co istnieje").
 * Pub/sub, fire-and-forget, efemeryczny (brak cache — nowy subskrybent
 * NIE dostaje starych eventów).
 *
 * Rozszerzalny do cross-tab (BroadcastChannel) i cross-microfrontend (postMessage).
 */
import type { Observable } from 'rxjs';
import type { CorrelationId, EventId } from '../identity/index.js';
export interface EchelonEvent<TPayload = unknown> {
    readonly id: EventId;
    /** Dot-case domain event name, np. `fx.transaction.submit`. */
    readonly type: string;
    readonly payload: TPayload;
    readonly at: number;
    readonly correlationId: CorrelationId;
    readonly source?: string;
    readonly meta?: Readonly<Record<string, unknown>>;
}
export interface EventBus {
    readonly stream$: Observable<EchelonEvent>;
    /** Filtrowany strumień po typie eventu (dokładnym albo glob `fx.*`). */
    on<T = unknown>(typePattern: string): Observable<EchelonEvent<T>>;
    emit(type: string, payload: unknown, options?: {
        correlationId?: CorrelationId;
        source?: string;
    }): void;
}
export declare const EVENT_BUS: import("../index.js").EchelonToken<EventBus>;
//# sourceMappingURL=index.d.ts.map