import { type Id } from '../identifier.utils.js'; /** * Parameters for the flush unsaved buffers command. */ export type FlushUnsavedBuffer = { /** Stream identifier */ streamId: Id; /** Topic identifier */ topicId: Id; /** Partition ID to flush */ partitionId: number; }; /** * Flush unsaved buffers command definition. * Forces buffered messages to be persisted to disk. */ export declare const FLUSH_UNSAVED_BUFFERS: { code: number; serialize: ({ streamId, topicId, partitionId }: FlushUnsavedBuffer) => Buffer; deserialize: (r: import("../../index.js").CommandResponse) => boolean; }; /** * Executable flush unsaved buffers command function. */ export declare const flushUnsavedBuffers: (getClient: import("../../index.js").ClientProvider) => (arg: FlushUnsavedBuffer) => Promise; //# sourceMappingURL=flush-unsaved-buffers.command.d.ts.map