//#region ../@warlock.js/herald/src/types/connection.types.d.ts
type BaseConnectionOptions = {
  name?: string;
  isDefault?: boolean;
};
type RabbitMQSocketOptions = {
  keepAlive?: boolean | number;
  noDelay?: boolean;
  timeout?: number;
  ca?: string | Buffer | Array<string | Buffer>;
  cert?: string | Buffer;
  key?: string | Buffer;
  passphrase?: string;
  servername?: string;
  rejectUnauthorized?: boolean;
};
type RabbitMQClientOptions = {
  frameMax?: number;
  channelMax?: number;
  locale?: string;
  socket?: RabbitMQSocketOptions;
};
type RabbitMQConnectionOptions<TClientOptions extends RabbitMQClientOptions = RabbitMQClientOptions> = BaseConnectionOptions & {
  driver: "rabbitmq";
  host?: string;
  port?: number;
  username?: string;
  password?: string;
  vhost?: string;
  uri?: string;
  heartbeat?: number;
  connectionTimeout?: number;
  reconnect?: boolean;
  reconnectDelay?: number;
  prefetch?: number;
  clientOptions?: TClientOptions;
};
type KafkaClientOptions = {
  retry?: {
    initialRetryTime?: number;
    retries?: number;
    maxRetryTime?: number;
    factor?: number;
    multiplier?: number;
  };
  logLevel?: number;
  logCreator?: any;
};
type KafkaConnectionOptions<TClientOptions extends KafkaClientOptions = KafkaClientOptions> = BaseConnectionOptions & {
  driver: "kafka";
  brokers: string[];
  clientId?: string;
  connectionTimeout?: number;
  requestTimeout?: number;
  ssl?: boolean | object;
  sasl?: {
    mechanism: "plain" | "scram-sha-256" | "scram-sha-512";
    username: string;
    password: string;
  };
  clientOptions?: TClientOptions;
};
type ConnectionOptions = RabbitMQConnectionOptions | KafkaConnectionOptions;
type BrokerConfigurations<TClientOptions = any> = RabbitMQConnectionOptions<TClientOptions extends RabbitMQClientOptions ? TClientOptions : RabbitMQClientOptions> | KafkaConnectionOptions<TClientOptions extends KafkaClientOptions ? TClientOptions : KafkaClientOptions>;
//#endregion
export { BaseConnectionOptions, BrokerConfigurations, ConnectionOptions, KafkaClientOptions, KafkaConnectionOptions, RabbitMQClientOptions, RabbitMQConnectionOptions, RabbitMQSocketOptions };
//# sourceMappingURL=connection.types.d.mts.map