import type { CommandResponse } from '../../client/client.type.js'; import type { Id } from '../identifier.utils.js'; import { type Consumer, type OffsetResponse } from './offset.utils.js'; /** * Parameters for the get offset command. */ export type GetOffset = { /** 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; }; /** * Get offset command definition. * Retrieves the current and stored offset for a consumer. */ export declare const GET_OFFSET: { code: number; serialize: ({ streamId, topicId, consumer, partitionId }: GetOffset) => Buffer; deserialize: (r: CommandResponse) => { partitionId: number; currentOffset: bigint; storedOffset: bigint; } | null; }; /** * Executable get offset command function. */ export declare const getOffset: (getClient: import("../../client/client.type.js").ClientProvider) => (arg: GetOffset) => Promise; //# sourceMappingURL=get-offset.command.d.ts.map