import { CommandParser } from '../client/parser'; import { RedisArgument, TuplesReply, BlobStringReply, ArrayReply, NullReply, TypeMapping } from '../RESP/types'; import { StreamMessageRawReply } from './generic-transformers'; /** * Options for the XAUTOCLAIM command * * @property COUNT - Limit the number of messages to claim */ export interface XAutoClaimOptions { COUNT?: number; } /** * Raw reply structure for XAUTOCLAIM command * * @property nextId - The ID to use for the next XAUTOCLAIM call * @property messages - Array of claimed messages or null entries * @property deletedMessages - Array of message IDs that no longer exist */ export type XAutoClaimRawReply = TuplesReply<[ nextId: BlobStringReply, messages: ArrayReply, deletedMessages: ArrayReply ]>; declare const _default: { readonly IS_READ_ONLY: false; readonly parseCommand: (this: void, parser: CommandParser, key: RedisArgument, group: RedisArgument, consumer: RedisArgument, minIdleTime: number, start: RedisArgument, options?: XAutoClaimOptions) => void; /** * Transforms the raw XAUTOCLAIM reply into a structured object * * @param reply - Raw reply from Redis * @param preserve - Preserve options (unused) * @param typeMapping - Type mapping for message fields * @returns Structured object containing nextId, messages, and deletedMessages */ readonly transformReply: (this: void, reply: [nextId: BlobStringReply, messages: ArrayReply, deletedMessages: ArrayReply>], preserve?: unknown, typeMapping?: TypeMapping) => { nextId: BlobStringReply; messages: (NullReply | import("./generic-transformers").StreamMessageReply)[]; deletedMessages: ArrayReply>; }; }; export default _default; //# sourceMappingURL=XAUTOCLAIM.d.ts.map