import { E as Events } from './overrides-6Hxg764S.js';
import * as valleyed from 'valleyed';
import { PipeOutput } from 'valleyed';

type StreamOptions = {
    skipScope?: boolean;
    fanout: boolean;
};
declare abstract class EventBus {
    abstract createStream<Event extends Events[keyof Events]>(topic: Event['topic'], options?: Partial<StreamOptions>): {
        publish: (data: Event['data']) => Promise<boolean>;
        subscribe: (onMessage: (data: Event['data']) => Promise<void>) => void;
    };
}

declare const rabbitmqConfigPipe: () => valleyed.Pipe<{
    uri: string;
    eventColumnName: string;
}, {
    uri: string;
    eventColumnName: string;
}>;
declare const kafkaConfigPipe: () => valleyed.Pipe<{
    brokers: string[];
    ssl: boolean | undefined;
    sasl: {
        mechanism: "plain";
        username: string;
        password: string;
    } | undefined;
    clientId: string | undefined;
}, {
    brokers: string[];
    ssl: boolean | undefined;
    sasl: {
        mechanism: "plain";
        username: string;
        password: string;
    } | undefined;
    clientId: string | undefined;
}>;
type KafkaConfig = PipeOutput<ReturnType<typeof kafkaConfigPipe>>;
type RabbitMQConfig = PipeOutput<ReturnType<typeof rabbitmqConfigPipe>>;

declare class KafkaEventBus extends EventBus {
    #private;
    constructor(config: KafkaConfig);
    createStream<Event extends Events[keyof Events]>(topicName: Event['topic'], options?: Partial<StreamOptions>): {
        publish: (data: Event["data"]) => Promise<boolean>;
        subscribe: (onMessage: (data: Event["data"]) => Promise<void>) => void;
    };
}

export { EventBus as E, KafkaEventBus as K, type RabbitMQConfig as R, type StreamOptions as S, type KafkaConfig as a, kafkaConfigPipe as k, rabbitmqConfigPipe as r };