/**
 * Redis Streamer Implementation
 *
 * This file implements the Streamer interface using Redis Streams and Pub/Sub:
 * - Redis Streams for persistent, ordered chunk storage
 * - Pub/Sub for real-time notifications to multiple consumers
 */
import type { Streamer } from '@workflow/world';
import type { Redis } from 'ioredis';
/**
 * Configuration for the streamer.
 */
export interface StreamerConfig {
    /**
     * Key prefix for all Redis keys.
     * Default: 'workflow'
     */
    keyPrefix?: string;
    /**
     * Maximum length of Redis Streams (approximate, uses ~).
     * Default: 10000
     */
    streamMaxLen?: number;
}
/**
 * Creates the Streamer implementation using Redis Streams.
 */
export declare function createStreamer(options: {
    redis: Redis;
    config?: StreamerConfig;
}): Promise<{
    streamer: Streamer;
    close: () => Promise<void>;
}>;
//# sourceMappingURL=streamer.d.ts.map