Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
54 commits
Select commit Hold shift + click to select a range
a45e885
import POC
nkaradzhov Jun 10, 2025
050ec94
use lowercase for command matching
nkaradzhov Jun 10, 2025
f1a2044
expose commandName getter
nkaradzhov Jun 10, 2025
cc42cb2
pass down command name and search policy
nkaradzhov Jun 10, 2025
77f2898
partially parse tips and key specs [skip ci]
nkaradzhov Jun 11, 2025
74d64c5
use response policies [skip ci]
nkaradzhov Jun 11, 2025
ccc20b4
parse subcommands, update static policies
nkaradzhov Jun 11, 2025
49975d1
fix tests
nkaradzhov Jun 11, 2025
0f9b7b5
resolve commands and subcommands
nkaradzhov Jun 18, 2025
653a189
add comments to all policies
nkaradzhov Jun 18, 2025
3555f87
POC partial implementation of request-response routing and aggregation
nkaradzhov Jun 18, 2025
d288c0a
extract request/response policy branches into named dispatch helpers
nkaradzhov Jun 8, 2026
f2d6306
replace policy switches with strategy registries in `_execute`
nkaradzhov Jun 8, 2026
e8f26c9
stabilize policy resolver: consistent casing + safer subcommand handling
nkaradzhov Jun 8, 2026
2457a5a
align Search policy entries with the HLD command routing table
nkaradzhov Jun 8, 2026
e040180
feat(client): add static-policies-data generator
nkaradzhov Jun 11, 2026
8746932
fix(client): scan all tips when parsing command policies
nkaradzhov Jun 11, 2026
61c6012
feat(client): parse COMMAND key specs into CommandReply
nkaradzhov Jun 11, 2026
63bab91
feat(client): carry key specs into multi_shard command policies
nkaradzhov Jun 11, 2026
30d864d
feat(client): add multi_shard command splitter
nkaradzhov Jun 12, 2026
7f6f19a
refactor(client): extract policy dispatch into _executeWithPolicies
nkaradzhov Jun 12, 2026
482e6fa
fix(client): correct default policy reducers
nkaradzhov Jun 12, 2026
332e601
fix(client): connect nodes lazily in all-shards/all-nodes fan-out
nkaradzhov Jun 12, 2026
8185f97
feat(client): wire multi_shard splitter into cluster dispatch
nkaradzhov Jun 16, 2026
7a1e0dd
fix(client): fall back to default policy for unknown cluster commands
nkaradzhov Jun 16, 2026
29a7f46
fix(client): route and split the raw cluster sendCommand path correctly
nkaradzhov Jun 16, 2026
44e7cd2
feat(client): implement special-policy reducers + safe fallback
nkaradzhov Jul 1, 2026
b790a82
feat(client): sticky FT.CURSOR routing via special request policy
nkaradzhov Jul 2, 2026
1782bf5
refactor(client): derive command routing/cache fields from server COM…
nkaradzhov Jul 15, 2026
e607c15
feat(client): implement cluster-wide SCAN and RANDOMKEY special policies
nkaradzhov Jul 16, 2026
1787c1b
fix(client): let IS_READ_ONLY/CACHEABLE overrides win over derived me…
nkaradzhov Jul 17, 2026
862dd29
fix(client): aggregate cluster fan-out replies before type mapping
nkaradzhov Jul 17, 2026
f9f9710
fix(client): route MSETEX single-node instead of multi_shard split
nkaradzhov Jul 17, 2026
bb743f2
feat(client): virtualize FT cursor ids with client-minted tokens
nkaradzhov Jul 17, 2026
d0c6fff
test(client): replace stale CROSSSLOT mGet assertion with split behavior
nkaradzhov Jul 17, 2026
0207506
fix(client): connect keyless-routed nodes lazily in cluster dispatch
nkaradzhov Jul 17, 2026
559ebb2
fix(client): surface a shard error from one_succeeded instead of Aggr…
nkaradzhov Jul 17, 2026
d5cba5a
fix(client): correct aggregateLogicalOr seed and validation
nkaradzhov Jul 17, 2026
795cade
fix(client): throw standard not-ready errors from cluster fan-out routes
nkaradzhov Jul 17, 2026
64fd332
fix(client): parse pre-7.0 COMMAND replies without throwing
nkaradzhov Jul 17, 2026
3049431
fix(client): forward malformed raw cursor commands to the server
nkaradzhov Jul 17, 2026
02b36d7
fix(client): restore slotNumber threading through cluster _execute
nkaradzhov Jul 17, 2026
c1938a6
fix(client): exclude VRANDMEMBER from client-side caching
nkaradzhov Jul 20, 2026
7253d2d
perf(client): skip CSC eligibility work when caching is disabled
nkaradzhov Jul 20, 2026
6e599b5
perf(client): memoize the parser command identifier
nkaradzhov Jul 20, 2026
8aec344
perf(client): fast-path default-keyed cluster commands
nkaradzhov Jul 20, 2026
0b60e85
fix(client): attribute post-reply hooks to the redirected serving node
nkaradzhov Jul 20, 2026
6f3335c
chore(client): remove scratch and one-off review artifacts
nkaradzhov Jul 20, 2026
02b56d0
fix(client): widen the served client through unknown at the hook boun…
nkaradzhov Jul 20, 2026
a7dac4b
refactor(client): dedupe policy-layer helpers and prune dead resolver…
nkaradzhov Jul 20, 2026
689af4d
fix(client): harden policy dispatch and resolver lookups
nkaradzhov Jul 20, 2026
7d0de80
refactor(client): drop vestigial script flag from CSC eligibility
nkaradzhov Jul 24, 2026
8f70362
chore(client): regenerate command metadata from Redis 8.9.241
nkaradzhov Jul 24, 2026
ded408f
feat(client): add HIMPORT command family with managed fieldset lifecycle
nkaradzhov Jul 27, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/ADD.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformBooleanReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('BF.ADD');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/CARD.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, NumberReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('BF.CARD');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/EXISTS.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformBooleanReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('BF.EXISTS');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/INFO.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ export type BfInfoReplyMap = TuplesToMapReply<[
]>;

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('BF.INFO');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/INSERT.ts
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ export interface BfInsertOptions {
}

export default {
IS_READ_ONLY: false,
parseCommand(
parser: CommandParser,
key: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/LOADCHUNK.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, SimpleStringReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, iterator: number, chunk: RedisArgument) {
parser.push('BF.LOADCHUNK');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/MADD.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import { RedisVariadicArgument } from '@redis/client/dist/lib/commands/generic-t
import { transformBooleanArrayReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, items: RedisVariadicArgument) {
parser.push('BF.MADD');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/MEXISTS.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import { RedisVariadicArgument } from '@redis/client/dist/lib/commands/generic-t
import { transformBooleanArrayReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, items: RedisVariadicArgument) {
parser.push('BF.MEXISTS');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/RESERVE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ export interface BfReserveOptions {
}

export default {
IS_READ_ONLY: true,
parseCommand(
parser: CommandParser,
key: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/bloom/SCANDUMP.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, TuplesReply, NumberReply, BlobStringReply, UnwrapReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, iterator: number) {
parser.push('BF.SCANDUMP');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/count-min-sketch/INCRBY.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ export interface BfIncrByItem {
}

export default {
IS_READ_ONLY: false,
parseCommand(
parser: CommandParser,
key: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/count-min-sketch/INFO.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ export interface CmsInfoReply {
}

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('CMS.INFO');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/count-min-sketch/INITBYDIM.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, SimpleStringReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, width: number, depth: number) {
parser.push('CMS.INITBYDIM');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/count-min-sketch/INITBYPROB.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, SimpleStringReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, error: number, probability: number) {
parser.push('CMS.INITBYPROB');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/count-min-sketch/MERGE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@ interface BfMergeSketch {
export type BfMergeSketches = Array<RedisArgument> | Array<BfMergeSketch>;

export default {
IS_READ_ONLY: false,
parseCommand(
parser: CommandParser,
destination: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/count-min-sketch/QUERY.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { ArrayReply, NumberReply, Command, RedisArgument } from '@redis/client/d
import { RedisVariadicArgument } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, items: RedisVariadicArgument) {
parser.push('CMS.QUERY');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/ADD.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformBooleanReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('CF.ADD');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/ADDNX.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformBooleanReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('CF.ADDNX');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/COUNT.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, NumberReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('CF.COUNT');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/DEL.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformBooleanReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('CF.DEL');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/EXISTS.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformBooleanReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, item: RedisArgument) {
parser.push('CF.EXISTS');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/INFO.ts
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ export type CfInfoReplyMap = TuplesToMapReply<[
]>;

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('CF.INFO');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/INSERT.ts
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ export function parseCfInsertArguments(
}

export default {
IS_READ_ONLY: false,
parseCommand(...args: Parameters<typeof parseCfInsertArguments>) {
args[0].push('CF.INSERT');
parseCfInsertArguments(...args);
Expand Down
3 changes: 1 addition & 2 deletions packages/bloom/lib/commands/cuckoo/INSERTNX.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { ArrayReply, Command, NumberReply } from '@redis/client/dist/lib/RESP/types';
import INSERT, { parseCfInsertArguments } from './INSERT';
import { parseCfInsertArguments } from './INSERT';

/**
* Adds one or more items to a Cuckoo Filter only if they do not exist yet, creating the filter if needed
Expand All @@ -11,7 +11,6 @@ import INSERT, { parseCfInsertArguments } from './INSERT';
* @param options.NOCREATE - If true, prevents automatic filter creation
*/
export default {
IS_READ_ONLY: INSERT.IS_READ_ONLY,
parseCommand(...args: Parameters<typeof parseCfInsertArguments>) {
args[0].push('CF.INSERTNX');
parseCfInsertArguments(...args);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/LOADCHUNK.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { SimpleStringReply, Command, RedisArgument } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, iterator: number, chunk: RedisArgument) {
parser.push('CF.LOADCHUNK');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/RESERVE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ export interface CfReserveOptions {
}

export default {
IS_READ_ONLY: false,
parseCommand(
parser: CommandParser,
key: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/cuckoo/SCANDUMP.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, TuplesReply, NumberReply, BlobStringReply, NullReply, UnwrapReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, iterator: number) {
parser.push('CF.SCANDUMP');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/ADD.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { SimpleStringReply, Command, RedisArgument } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, values: Array<number>) {
parser.push('TDIGEST.ADD');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/BYRANK.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ export function transformByRankArguments(
}

export default {
IS_READ_ONLY: true,
parseCommand(...args: Parameters<typeof transformByRankArguments>) {
args[0].push('TDIGEST.BYRANK');
transformByRankArguments(...args);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/BYREVRANK.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ import BYRANK, { transformByRankArguments } from './BYRANK';
* @param ranks - Array of ranks to get value estimates for (descending order)
*/
export default {
IS_READ_ONLY: BYRANK.IS_READ_ONLY,
parseCommand(...args: Parameters<typeof transformByRankArguments>) {
args[0].push('TDIGEST.BYREVRANK');
transformByRankArguments(...args);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/CDF.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformDoubleArrayReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, values: Array<number>) {
parser.push('TDIGEST.CDF');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/CREATE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ export interface TDigestCreateOptions {
}

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, options?: TDigestCreateOptions) {
parser.push('TDIGEST.CREATE');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/INFO.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ export type TdInfoReplyMap = TuplesToMapReply<[
]>;

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TDIGEST.INFO');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/MAX.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformDoubleReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TDIGEST.MAX');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/MERGE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ export interface TDigestMergeOptions {
}

export default {
IS_READ_ONLY: false,
parseCommand(
parser: CommandParser,
destination: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/MIN.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformDoubleReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TDIGEST.MIN');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/QUANTILE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformDoubleArrayReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, quantiles: Array<number>) {
parser.push('TDIGEST.QUANTILE');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/RANK.ts
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ export function transformRankArguments(
}

export default {
IS_READ_ONLY: true,
parseCommand(...args: Parameters<typeof transformRankArguments>) {
args[0].push('TDIGEST.RANK');
transformRankArguments(...args);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/RESET.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, SimpleStringReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TDIGEST.RESET');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/REVRANK.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ import RANK, { transformRankArguments } from './RANK';
* @param values - Array of values to get reverse ranks for
*/
export default {
IS_READ_ONLY: RANK.IS_READ_ONLY,
parseCommand(...args: Parameters<typeof transformRankArguments>) {
args[0].push('TDIGEST.REVRANK');
transformRankArguments(...args);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/t-digest/TRIMMED_MEAN.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { transformDoubleReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(
parser: CommandParser,
key: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/ADD.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, ArrayReply, BlobStringReply, Command } from '@redis/clie
import { RedisVariadicArgument } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, items: RedisVariadicArgument) {
parser.push('TOPK.ADD');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/COUNT.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, ArrayReply, NumberReply, Command } from '@redis/client/d
import { RedisVariadicArgument } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument, items: RedisVariadicArgument) {
parser.push('TOPK.COUNT');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/INCRBY.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ function pushIncrByItem(parser: CommandParser, { item, incrementBy }: TopKIncrBy
}

export default {
IS_READ_ONLY: false,
parseCommand(
parser: CommandParser,
key: RedisArgument,
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/INFO.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ export type TopKInfoReplyMap = TuplesToMapReply<[
]>;

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TOPK.INFO');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/LIST.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, ArrayReply, BlobStringReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TOPK.LIST');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/LIST_WITHCOUNT.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ import { CommandParser } from '@redis/client/dist/lib/client/parser';
import { RedisArgument, ArrayReply, BlobStringReply, NumberReply, UnwrapReply, Command } from '@redis/client/dist/lib/RESP/types';

export default {
IS_READ_ONLY: true,
parseCommand(parser: CommandParser, key: RedisArgument) {
parser.push('TOPK.LIST');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/QUERY.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ import { RedisArgument, Command } from '@redis/client/dist/lib/RESP/types';
import { RedisVariadicArgument, transformBooleanArrayReply } from '@redis/client/dist/lib/commands/generic-transformers';

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, items: RedisVariadicArgument) {
parser.push('TOPK.QUERY');
parser.pushKey(key);
Expand Down
1 change: 0 additions & 1 deletion packages/bloom/lib/commands/top-k/RESERVE.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ export interface TopKReserveOptions {
}

export default {
IS_READ_ONLY: false,
parseCommand(parser: CommandParser, key: RedisArgument, topK: number, options?: TopKReserveOptions) {
parser.push('TOPK.RESERVE');
parser.pushKey(key);
Expand Down
Loading
Loading