import { type Id } from '../identifier.utils.js'; import { type Consumer } from './offset.utils.js'; /** * Parameters for the store offset command. */ export type StoreOffset = { /** Stream identifier (ID or name) */ streamId: Id; /** Topic identifier (ID or name) */ topicId: Id; /** Consumer identifier (single or group) */ consumer: Consumer; /** Partition ID. VSR requires the explicit partition returned by polling. */ partitionId: number | null; /** Offset value to store */ offset: bigint; }; /** * Store offset command definition. * Persists a consumer's offset for a partition. */ export declare const STORE_OFFSET: { code: number; serialize: ({ streamId, topicId, consumer, partitionId, offset }: StoreOffset) => Buffer; deserialize: (r: import("../../index.js").CommandResponse) => boolean; }; /** * Executable store offset command function. */ export declare const storeOffset: (getClient: import("../../index.js").ClientProvider) => (arg: StoreOffset) => Promise; //# sourceMappingURL=store-offset.command.d.ts.map