diff --git a/lib/utils/RedisCommander.ts b/lib/utils/RedisCommander.ts index 49388d8ed..d62585836 100644 --- a/lib/utils/RedisCommander.ts +++ b/lib/utils/RedisCommander.ts @@ -8547,8 +8547,8 @@ interface RedisCommander { consumer: string | Buffer, minIdleTime: string | Buffer | number, start: string | Buffer | number, - callback?: Callback - ): Result; + callback?: Callback<[id: string, messages: [id: string, fields: string[]][]][]> + ): Result<[id: string, messages: [id: string, fields: string[]][]][], Context>; xautoclaim( key: RedisKey, group: string | Buffer, @@ -8556,8 +8556,8 @@ interface RedisCommander { minIdleTime: string | Buffer | number, start: string | Buffer | number, justid: "JUSTID", - callback?: Callback - ): Result; + callback?: Callback<[id: string, messages: [id: string, fields: string[]][]][]> + ): Result<[id: string, messages: [id: string, fields: string[]][]][], Context>; xautoclaim( key: RedisKey, group: string | Buffer, @@ -8566,8 +8566,8 @@ interface RedisCommander { start: string | Buffer | number, countToken: "COUNT", count: number | string, - callback?: Callback - ): Result; + callback?: Callback<[id: string, messages: [id: string, fields: string[]][]][]> + ): Result<[id: string, messages: [id: string, fields: string[]][]][], Context>; xautoclaim( key: RedisKey, group: string | Buffer, @@ -8577,8 +8577,46 @@ interface RedisCommander { countToken: "COUNT", count: number | string, justid: "JUSTID", - callback?: Callback - ): Result; + callback?: Callback<[id: string, messages: [id: string, fields: string[]][]][]> + ): Result<[id: string, messages: [id: string, fields: string[]][]], Context>; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + callback?: Callback<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]]> + ): Result<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]], Context>; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + justid: "JUSTID", + callback?: Callback<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]]> + ): Result<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]], Context>; + xautoclaimBuffer( + key: RedisKey, + group: string | Buffer, + consumer: string | Buffer, + minIdleTime: string | Buffer | number, + start: string | Buffer | number, + countToken: "COUNT", + count: number | string, + callback?: Callback<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]]> + ): Result<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]], Context>; + 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<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]]> + ): Result<[id: Buffer, messages: [id: Buffer, fields: Buffer[]][][]], Context>; /** * Changes (or acquires) ownership of a message in a consumer group, as if the message was delivered to the specified consumer. @@ -9770,8 +9808,8 @@ interface RedisCommander { key: RedisKey, start: string | Buffer | number, end: string | Buffer | number, - callback?: Callback<[id: Buffer, fields: Buffer[]][]> - ): Result<[id: Buffer, fields: Buffer[]][], Context>; + callback?: Callback<[id: Buffer, fields: Buffer[]][][]> + ): Result<[id: Buffer, fields: Buffer[]][][], Context>; xrange( key: RedisKey, start: string | Buffer | number, @@ -9786,8 +9824,8 @@ interface RedisCommander { end: string | Buffer | number, countToken: "COUNT", count: number | string, - callback?: Callback<[id: Buffer, fields: Buffer[]][]> - ): Result<[id: Buffer, fields: Buffer[]][], Context>; + callback?: Callback<[id: Buffer, fields: Buffer[]][][]> + ): Result<[id: Buffer, fields: Buffer[]][][], Context>; /** * Return never seen elements in multiple streams, with IDs greater than the ones reported by the caller for each stream. Can block. @@ -9812,11 +9850,11 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[], callback: Callback< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null > ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9828,7 +9866,7 @@ interface RedisCommander { xreadBuffer( ...args: [streamsToken: "STREAMS", ...args: RedisValue[]] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9852,11 +9890,11 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[], callback: Callback< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null > ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9878,7 +9916,7 @@ interface RedisCommander { ...args: RedisValue[] ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9902,11 +9940,11 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[], callback: Callback< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null > ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9928,7 +9966,7 @@ interface RedisCommander { ...args: RedisValue[] ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9956,11 +9994,11 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[], callback: Callback< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null > ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; xread( @@ -9986,7 +10024,7 @@ interface RedisCommander { ...args: RedisValue[] ] ): Result< - [key: Buffer, items: [id: Buffer, fields: Buffer[]][]][] | null, + [key: Buffer, items: [id: Buffer, fields: Buffer[]][][]][] | null, Context >; @@ -10003,9 +10041,9 @@ interface RedisCommander { consumer: string | Buffer, streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback<[key: string, entries: [id: string, fields: string[]][]][]> ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10014,7 +10052,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10023,9 +10061,9 @@ interface RedisCommander { noack: "NOACK", streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback<[key: string, entries: [id: string, fields: string[]][]][]> ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10035,7 +10073,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10045,9 +10083,9 @@ interface RedisCommander { milliseconds: number | string, streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10058,7 +10096,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10069,9 +10107,9 @@ interface RedisCommander { noack: "NOACK", streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10083,7 +10121,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10093,9 +10131,9 @@ interface RedisCommander { count: number | string, streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback<[key: string, entries: [id: string, fields: string[]][]][]> ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10106,7 +10144,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10117,9 +10155,9 @@ interface RedisCommander { noack: "NOACK", streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback<[key: string, entries: [id: string, fields: string[]][]][]> ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10131,7 +10169,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result<[key: string, entries: [id: string, fields: string[]][]][], Context>; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10143,9 +10181,9 @@ interface RedisCommander { milliseconds: number | string, streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10158,7 +10196,7 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10171,9 +10209,9 @@ interface RedisCommander { noack: "NOACK", streamsToken: "STREAMS", ...args: RedisValue[], - callback: Callback + callback: Callback ] - ): Result; + ): Result; xreadgroup( ...args: [ groupConsumerToken: "GROUP", @@ -10187,7 +10225,199 @@ interface RedisCommander { streamsToken: "STREAMS", ...args: RedisValue[] ] - ): Result; + ): Result; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][]> + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][]> + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + 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<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][]> + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result<[key: string, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[], + callback: Callback<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][]> + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + xreadgroupBuffer( + ...args: [ + groupConsumerToken: "GROUP", + group: string | Buffer, + consumer: string | Buffer, + countToken: "COUNT", + count: number | string, + noack: "NOACK", + streamsToken: "STREAMS", + ...args: RedisValue[] + ] + ): Result<[key: Buffer, entries: [id: Buffer, fields: Buffer[]][]][], Context>; + 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 @@ -10205,8 +10435,8 @@ interface RedisCommander { key: RedisKey, end: string | Buffer | number, start: string | Buffer | number, - callback?: Callback<[id: Buffer, fields: Buffer[]][]> - ): Result<[id: Buffer, fields: Buffer[]][], Context>; + callback?: Callback<[id: Buffer, fields: Buffer[]][][]> + ): Result<[id: Buffer, fields: Buffer[]][][], Context>; xrevrange( key: RedisKey, end: string | Buffer | number, @@ -10221,8 +10451,8 @@ interface RedisCommander { start: string | Buffer | number, countToken: "COUNT", count: number | string, - callback?: Callback<[id: Buffer, fields: Buffer[]][]> - ): Result<[id: Buffer, fields: Buffer[]][], Context>; + callback?: Callback<[id: Buffer, fields: Buffer[]][][]> + ): Result<[id: Buffer, fields: Buffer[]][][], Context>; /** * An internal command for replicating stream values