/**
 * Secured SQL adapter for worker routers.
 *
 * Replaces raw SQL with calls to SECURITY DEFINER stored procedures.
 * Workers using this adapter can only access their allowed streams —
 * the stored procedures validate `app.allowed_streams` before executing.
 */
import { ILogger } from '../../../logger';
import { PostgresClientType } from '../../../../types/postgres';
import { ProviderClient } from '../../../../types/provider';
import { StreamMessage } from '../../../../types/stream';
/**
 * Dequeue messages from worker_streams via stored procedure.
 */
export declare function fetchMessagesSecured(client: PostgresClientType & ProviderClient, schema: string, streamName: string, consumerName: string, options: {
    batchSize?: number;
    reservationTimeout?: number;
    enableBackoff?: boolean;
    initialBackoff?: number;
    maxBackoff?: number;
    maxRetries?: number;
}, logger: ILogger): Promise<StreamMessage[]>;
/**
 * Ack/delete messages via stored procedure.
 */
export declare function ackAndDeleteSecured(client: PostgresClientType & ProviderClient, schema: string, streamName: string, messageIds: string[], logger: ILogger): Promise<number>;
/**
 * Dead-letter messages via stored procedure.
 */
export declare function deadLetterMessagesSecured(client: PostgresClientType & ProviderClient, schema: string, streamName: string, messageIds: string[], logger: ILogger): Promise<number>;
/**
 * Publish a response to engine_streams via stored procedure.
 */
export declare function publishMessagesSecured(client: PostgresClientType & ProviderClient, schema: string, streamName: string, messages: string[], logger: ILogger): Promise<string[]>;