import type { Publisher } from '@orpc/publisher';
import type { RedisClient } from 'bun';
export type RealtimeAction = 'create' | 'update' | 'delete';
export interface RealtimeChange {
    table: string;
    action: RealtimeAction;
    record: Record<string, unknown>;
    /** Correlates this confirmed write with the client operation that caused it. */
    operationId?: string;
}
export interface RealtimeEvents extends Record<string, object> {
    change: RealtimeChange;
}
export type RealtimePublisher = Publisher<RealtimeEvents>;
export interface RealtimePublisherOptions {
    maxBufferedEvents?: number;
    resumeSeconds?: number;
}
export declare function createMemoryRealtimePublisher(options?: RealtimePublisherOptions): RealtimePublisher;
export declare function createRedisRealtimePublisher(redis: RedisClient, subscriber: RedisClient | Promise<RedisClient>, options?: RealtimePublisherOptions & {
    prefix?: string;
}): RealtimePublisher;
//# sourceMappingURL=publisher.d.ts.map