import { PubSub, UnixSocketPubSub } from '@mastra/core/events';
import type { PubSubDeliveryMode, Event, EventCallback, SubscribeOptions } from '@mastra/core/events';
/**
 * A PubSub that manages one Unix socket per thread for cross-process signal
 * coordination within a mastracode resource.
 *
 * Socket paths use `/tmp/mc/<resourceId>/<threadId>.sock` for inspectability
 * and automatic OS cleanup. Each thread gets its own isolated socket so
 * processes on different threads never exchange data. A solo process on a
 * thread has zero serialization overhead.
 */
declare class SignalsPubSub extends PubSub {
    #private;
    constructor(resourceId: string);
    get supportedModes(): ReadonlyArray<PubSubDeliveryMode>;
    publish(topic: string, event: Omit<Event, 'id' | 'createdAt'>): Promise<void>;
    subscribe(topic: string, cb: EventCallback, options?: SubscribeOptions): Promise<void>;
    unsubscribe(topic: string, cb: EventCallback): Promise<void>;
    flush(): Promise<void>;
    close(): Promise<void>;
    /** Get the underlying socket for a topic (for testing/inspection). */
    getSocket(topic: string): UnixSocketPubSub | undefined;
}
/**
 * Creates a per-thread PubSub for cross-process signal coordination.
 *
 * Each thread gets its own Unix socket under `/tmp/mc/<resourceId>/`.
 * Processes on different threads never exchange data. A solo process on a
 * thread has zero serialization overhead — the broker only serializes when
 * another process joins the same thread's socket.
 */
export declare function createSignalsPubSub(resourceId: string): SignalsPubSub;
export {};
//# sourceMappingURL=signals-pubsub.d.ts.map