import { ChannelOptions } from "../types/channel.types.mjs";
import { HealthCheckResult } from "../types/driver.types.mjs";
import { ChannelContract } from "../contracts/channel.contract.mjs";
import { EventMessage } from "../message-managers/event-message.mjs";
import { EventConsumerClass } from "../message-managers/types.mjs";
import { BrokerDriverContract } from "../contracts/broker-driver.contract.mjs";
//#region ../@warlock.js/herald/src/communicators/broker.d.ts
/**
 * Options for creating a Broker
 */
interface BrokerOptions {
  /** Unique name for this broker */
  name: string;
  /** The underlying driver */
  driver: BrokerDriverContract;
  /** Whether this is the default broker */
  isDefault?: boolean;
}
/**
 * Broker - wrapper around a driver with metadata
 *
 * Similar to DataSource in @warlock.js/cascade
 *
 * @example
 * ```typescript
 * const broker = new Broker({
 *   name: "default",
 *   driver: rabbitMQDriver,
 *   isDefault: true,
 * });
 *
 * // Get a channel
 * const channel = broker.channel("user.created");
 * ```
 */
declare class Broker {
  /** Unique name identifying this broker */
  readonly name: string;
  /** The underlying driver */
  readonly driver: BrokerDriverContract;
  /** Whether this is the default broker */
  readonly isDefault: boolean;
  /**
   * Create a new Broker
   *
   * @param options - Broker configuration
   */
  constructor(options: BrokerOptions);
  /**
   * Subscribe the given consumer
   */
  subscribe(consumer: EventConsumerClass<any>): () => void;
  /**
   * Publish the given event message
   */
  publish<TPayload = Record<string, any>>(event: EventMessage<TPayload>): void;
  /**
   * Get or create a channel
   *
   * @param name - Channel name
   * @param options - Channel options
   * @returns Channel instance
   *
   * @example
   * ```typescript
   * // Simple channel
   * const channel = broker.channel("notifications");
   *
   * // Typed channel with schema
   * const orderChannel = broker.channel<OrderPayload>("orders", {
   *   schema: OrderSchema,
   *   durable: true,
   * });
   * ```
   */
  channel<TPayload = unknown>(name: string, options?: ChannelOptions<TPayload>): ChannelContract<TPayload>;
  /**
   * Check if the broker is connected
   */
  get isConnected(): boolean;
  /**
   * Connect the underlying driver
   */
  connect(): Promise<void>;
  /**
   * Disconnect the underlying driver
   */
  disconnect(): Promise<void>;
  /**
   * Start consuming messages
   */
  startConsuming(): Promise<void>;
  /**
   * Stop consuming messages
   */
  stopConsuming(): Promise<void>;
  /**
   * Health check
   */
  healthCheck(): Promise<HealthCheckResult>;
}
//#endregion
export { Broker, BrokerOptions };
//# sourceMappingURL=broker.d.mts.map