import { ILogger } from '../../../logger';
import { PostgresClientType } from '../../../../types/postgres';
import { ProviderClient } from '../../../../types/provider';
/**
 * Create a stream (no-op for PostgreSQL - streams are created implicitly).
 */
export declare function createStream(streamName: string): Promise<boolean>;
/**
 * Delete a stream or all streams from a specific table.
 */
export declare function deleteStream(client: PostgresClientType & ProviderClient, tableName: string, streamName: string, logger: ILogger): Promise<boolean>;
/**
 * Create a consumer group (no-op for PostgreSQL - groups are created implicitly).
 */
export declare function createConsumerGroup(streamName: string, groupName: string): Promise<boolean>;
/**
 * Delete messages for a stream from a specific table.
 * No group_name needed since engine and worker are separate tables.
 */
export declare function deleteConsumerGroup(client: PostgresClientType & ProviderClient, tableName: string, streamName: string, logger: ILogger): Promise<boolean>;