From b8eeff7e222351beac4c7699784df05df15d3d59 Mon Sep 17 00:00:00 2001 From: Siarhei Fedartsou Date: Sat, 2 Nov 2024 11:13:06 +0100 Subject: [PATCH] Add *Buffer methods typings for XCLAIM/XAUTOCLAIM/XREADGROUP/XPENDING Signed-off-by: Siarhei Fedartsou --- lib/utils/RedisCommander.ts | 1222 +++++++++++++++++++++++++++++++++-- 1 file changed, 1182 insertions(+), 40 deletions(-) diff --git a/lib/utils/RedisCommander.ts b/lib/utils/RedisCommander.ts index 215ed50..0c838db 100644 --- a/lib/utils/RedisCommander.ts +++ b/lib/utils/RedisCommander.ts @@ -8580,6 +8580,46 @@ interface RedisCommander { callback?: Callback ): Result; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + callback?: Callback + ): Result; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + justid: "JUSTID", + callback?: Callback + ): Result; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + countToken: "COUNT", + count: number | string, + callback?: Callback + ): Result; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + countToken: "COUNT", + count: number | string, + justid: "JUSTID", + callback?: Callback + ): Result; + + /** * Changes (or acquires) ownership of a message in a consumer group, as if the message was delivered to the specified consumer. * - _group_: stream @@ -8870,7 +8910,872 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + force: "FORCE" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE" + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaim( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + msToken: "IDLE", + ms: number | string, + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[] + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + justid: "JUSTID" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + force: "FORCE", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + force: "FORCE" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + justid: "JUSTID" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + countToken: "RETRYCOUNT", + count: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + justid: "JUSTID" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE" + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE", + justid: "JUSTID", + callback: Callback + ] + ): Result; + xclaimBuffer( + ...args: [ + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + ...ids: (string | Buffer | number)[], + unixTimeMillisecondsToken: "TIME", + unixTimeMilliseconds: number | string, + force: "FORCE", + justid: "JUSTID" + ] + ): Result; + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8884,7 +9789,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8897,7 +9802,7 @@ interface RedisCommander { count: number | string ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8912,7 +9817,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8926,7 +9831,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8941,7 +9846,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8955,7 +9860,7 @@ interface RedisCommander { force: "FORCE" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8971,7 +9876,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8986,7 +9891,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -8998,7 +9903,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9009,7 +9914,7 @@ interface RedisCommander { ms: number | string ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9022,7 +9927,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9034,7 +9939,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9047,7 +9952,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9059,7 +9964,7 @@ interface RedisCommander { force: "FORCE" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9073,7 +9978,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9086,7 +9991,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9100,7 +10005,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9113,7 +10018,7 @@ interface RedisCommander { count: number | string ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9128,7 +10033,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9142,7 +10047,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9157,7 +10062,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9171,7 +10076,7 @@ interface RedisCommander { force: "FORCE" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9187,7 +10092,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9202,7 +10107,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9216,7 +10121,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9229,7 +10134,7 @@ interface RedisCommander { unixTimeMilliseconds: number | string ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9244,7 +10149,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9258,7 +10163,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9273,7 +10178,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9287,7 +10192,7 @@ interface RedisCommander { force: "FORCE" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9303,7 +10208,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9318,7 +10223,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9334,7 +10239,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9349,7 +10254,7 @@ interface RedisCommander { count: number | string ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9366,7 +10271,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9382,7 +10287,7 @@ interface RedisCommander { justid: "JUSTID" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9399,7 +10304,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9415,7 +10320,7 @@ interface RedisCommander { force: "FORCE" ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9433,7 +10338,7 @@ interface RedisCommander { callback: Callback ] ): Result; - xclaim( + xclaimBuffer( ...args: [ key: RedisKey, group: string | Buffer, @@ -9754,6 +10659,50 @@ interface RedisCommander { callback?: Callback ): Result; + xpendingBuffer( + key: RedisKey, + group: string | Buffer, + callback?: Callback + ): Result; + xpendingBuffer( + key: RedisKey, + group: string | Buffer, + start: string | Buffer | number, + end: string | Buffer | number, + count: number | string, + callback?: Callback + ): Result; + xpendingBuffer( + key: RedisKey, + group: string | Buffer, + start: string | Buffer | number, + end: string | Buffer | number, + count: number | string, + consumer: string | Buffer, + callback?: Callback + ): Result; + xpendingBuffer( + key: RedisKey, + group: string | Buffer, + minIdleTimeToken: "IDLE", + minIdleTime: number | string, + start: string | Buffer | number, + end: string | Buffer | number, + count: number | string, + callback?: Callback + ): Result; + xpendingBuffer( + key: RedisKey, + group: string | Buffer, + minIdleTimeToken: "IDLE", + minIdleTime: number | string, + start: string | Buffer | number, + end: string | Buffer | number, + count: number | string, + consumer: string | Buffer, + callback?: Callback + ): Result; + /** * Return a range of elements in a stream, with IDs matching the specified IDs interval * - _group_: stream @@ -10189,6 +11138,199 @@ interface RedisCommander { ] ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + millisecondsToken: "BLOCK", + milliseconds: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + millisecondsToken: "BLOCK", + milliseconds: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + millisecondsToken: "BLOCK", + milliseconds: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + millisecondsToken: "BLOCK", + milliseconds: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + millisecondsToken: "BLOCK", + milliseconds: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + millisecondsToken: "BLOCK", + milliseconds: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + millisecondsToken: "BLOCK", + milliseconds: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback + ] + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + millisecondsToken: "BLOCK", + milliseconds: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result; + /** * Return a range of elements in a stream, with IDs matching the specified IDs interval, in reverse order (from greater to smaller IDs) compared to XRANGE * - _group_: stream