/**
 * Event System - PubSub and Event Emitter for agent communication
 * Inspired by mastra's events module
 */
import { EventEmitter } from 'events';
export interface Event {
    id: string;
    topic: string;
    data: any;
    createdAt: Date;
    metadata?: Record<string, any>;
}
export type EventHandler = (event: Event, ack?: () => Promise<void>) => void | Promise<void>;
/**
 * Abstract PubSub base class
 */
export declare abstract class PubSub {
    abstract publish(topic: string, data: any, metadata?: Record<string, any>): Promise<void>;
    abstract subscribe(topic: string, handler: EventHandler): Promise<void>;
    abstract unsubscribe(topic: string, handler: EventHandler): Promise<void>;
    abstract close(): Promise<void>;
}
/**
 * In-memory EventEmitter-based PubSub implementation
 */
export declare class EventEmitterPubSub extends PubSub {
    private emitter;
    private handlers;
    constructor(existingEmitter?: EventEmitter);
    publish(topic: string, data: any, metadata?: Record<string, any>): Promise<void>;
    subscribe(topic: string, handler: EventHandler): Promise<void>;
    unsubscribe(topic: string, handler: EventHandler): Promise<void>;
    close(): Promise<void>;
    /**
     * Wait for a specific event with optional timeout
     */
    waitFor(topic: string, timeout?: number): Promise<Event>;
    /**
     * Get the underlying EventEmitter
     */
    getEmitter(): EventEmitter;
}
/**
 * Agent Event Bus - Specialized event system for agent communication
 */
export declare class AgentEventBus {
    private pubsub;
    private agentId;
    constructor(agentId: string, pubsub?: PubSub);
    /**
     * Emit an agent event
     */
    emit(eventType: string, data: any): Promise<void>;
    /**
     * Listen for agent events
     */
    on(eventType: string, handler: (data: any) => void | Promise<void>): Promise<void>;
    /**
     * Broadcast to all agents
     */
    broadcast(eventType: string, data: any): Promise<void>;
    /**
     * Listen for broadcast events
     */
    onBroadcast(eventType: string, handler: (data: any, sourceAgentId: string) => void | Promise<void>): Promise<void>;
    /**
     * Send message to specific agent
     */
    sendTo(targetAgentId: string, eventType: string, data: any): Promise<void>;
    close(): Promise<void>;
}
export declare const AgentEvents: {
    readonly STARTED: "started";
    readonly COMPLETED: "completed";
    readonly ERROR: "error";
    readonly TOOL_CALLED: "tool_called";
    readonly TOOL_RESULT: "tool_result";
    readonly MESSAGE_RECEIVED: "message_received";
    readonly MESSAGE_SENT: "message_sent";
    readonly HANDOFF_INITIATED: "handoff_initiated";
    readonly HANDOFF_COMPLETED: "handoff_completed";
};
export declare function createEventBus(agentId: string): AgentEventBus;
export declare function createPubSub(): EventEmitterPubSub;