@redis/client
Advanced tools
Comparing version 1.5.17 to 1.6.0
@@ -479,2 +479,8 @@ import * as ACL_CAT from '../commands/ACL_CAT'; | ||
hExists: typeof import("../commands/HEXISTS"); | ||
HEXPIRE: typeof import("../commands/HEXPIRE"); | ||
hExpire: typeof import("../commands/HEXPIRE"); | ||
HEXPIREAT: typeof import("../commands/HEXPIREAT"); | ||
hExpireAt: typeof import("../commands/HEXPIREAT"); | ||
HEXPIRETIME: typeof import("../commands/HEXPIRETIME"); | ||
hExpireTime: typeof import("../commands/HEXPIRETIME"); | ||
HGET: typeof import("../commands/HGET"); | ||
@@ -494,2 +500,12 @@ hGet: typeof import("../commands/HGET"); | ||
hmGet: typeof import("../commands/HMGET"); | ||
HPERSIST: typeof import("../commands/HPERSIST"); | ||
hPersist: typeof import("../commands/HPERSIST"); | ||
HPEXPIRE: typeof import("../commands/HPEXPIRE"); | ||
hpExpire: typeof import("../commands/HPEXPIRE"); | ||
HPEXPIREAT: typeof import("../commands/HPEXPIREAT"); | ||
hpExpireAt: typeof import("../commands/HPEXPIREAT"); | ||
HPEXPIRETIME: typeof import("../commands/HPEXPIRETIME"); | ||
hpExpireTime: typeof import("../commands/HPEXPIRETIME"); | ||
HPTTL: typeof import("../commands/HPTTL"); | ||
hpTTL: typeof import("../commands/HPTTL"); | ||
HRANDFIELD_COUNT_WITHVALUES: typeof import("../commands/HRANDFIELD_COUNT_WITHVALUES"); | ||
@@ -503,2 +519,4 @@ hRandFieldCountWithValues: typeof import("../commands/HRANDFIELD_COUNT_WITHVALUES"); | ||
hScan: typeof import("../commands/HSCAN"); | ||
HSCAN_NOVALUES: typeof import("../commands/HSCAN_NOVALUES"); | ||
hScanNoValues: typeof import("../commands/HSCAN_NOVALUES"); | ||
HSET: typeof import("../commands/HSET"); | ||
@@ -510,2 +528,4 @@ hSet: typeof import("../commands/HSET"); | ||
hStrLen: typeof import("../commands/HSTRLEN"); | ||
HTTL: typeof import("../commands/HTTL"); | ||
hTTL: typeof import("../commands/HTTL"); | ||
HVALS: typeof import("../commands/HVALS"); | ||
@@ -512,0 +532,0 @@ hVals: typeof import("../commands/HVALS"); |
/// <reference types="node" /> | ||
import COMMANDS from './commands'; | ||
import { RedisCommand, RedisCommandArguments, RedisCommandRawReply, RedisCommandReply, RedisFunctions, RedisModules, RedisExtensions, RedisScript, RedisScripts, RedisCommandSignature, ConvertArgumentType, RedisFunction, ExcludeMappedString } from '../commands'; | ||
import { RedisCommand, RedisCommandArgument, RedisCommandArguments, RedisCommandRawReply, RedisCommandReply, RedisFunctions, RedisModules, RedisExtensions, RedisScript, RedisScripts, RedisCommandSignature, ConvertArgumentType, RedisFunction, ExcludeMappedString } from '../commands'; | ||
import { RedisSocketOptions } from './socket'; | ||
@@ -141,2 +141,3 @@ import { QueueCommandOptions } from './commands-queue'; | ||
hScanIterator(key: string, options?: ScanOptions): AsyncIterable<ConvertArgumentType<HScanTuple, string>>; | ||
hScanNoValuesIterator(key: string, options?: ScanOptions): AsyncIterable<ConvertArgumentType<RedisCommandArgument, string>>; | ||
sScanIterator(key: string, options?: ScanOptions): AsyncIterable<string>; | ||
@@ -143,0 +144,0 @@ zScanIterator(key: string, options?: ScanOptions): AsyncIterable<ConvertArgumentType<ZMember, string>>; |
@@ -319,2 +319,12 @@ "use strict"; | ||
} | ||
async *hScanNoValuesIterator(key, options) { | ||
let cursor = 0; | ||
do { | ||
const reply = await this.hScanNoValues(key, cursor, options); | ||
cursor = reply.cursor; | ||
for (const k of reply.keys) { | ||
yield k; | ||
} | ||
} while (cursor !== 0); | ||
} | ||
async *sScanIterator(key, options) { | ||
@@ -321,0 +331,0 @@ let cursor = 0; |
@@ -55,2 +55,5 @@ import * as APPEND from '../commands/APPEND'; | ||
import * as HEXISTS from '../commands/HEXISTS'; | ||
import * as HEXPIRE from '../commands/HEXPIRE'; | ||
import * as HEXPIREAT from '../commands/HEXPIREAT'; | ||
import * as HEXPIRETIME from '../commands/HEXPIRETIME'; | ||
import * as HGET from '../commands/HGET'; | ||
@@ -63,2 +66,7 @@ import * as HGETALL from '../commands/HGETALL'; | ||
import * as HMGET from '../commands/HMGET'; | ||
import * as HPERSIST from '../commands/HPERSIST'; | ||
import * as HPEXPIRE from '../commands/HPEXPIRE'; | ||
import * as HPEXPIREAT from '../commands/HPEXPIREAT'; | ||
import * as HPEXPIRETIME from '../commands/HPEXPIRETIME'; | ||
import * as HPTTL from '../commands/HPTTL'; | ||
import * as HRANDFIELD_COUNT_WITHVALUES from '../commands/HRANDFIELD_COUNT_WITHVALUES'; | ||
@@ -68,5 +76,7 @@ import * as HRANDFIELD_COUNT from '../commands/HRANDFIELD_COUNT'; | ||
import * as HSCAN from '../commands/HSCAN'; | ||
import * as HSCAN_NOVALUES from '../commands/HSCAN_NOVALUES'; | ||
import * as HSET from '../commands/HSET'; | ||
import * as HSETNX from '../commands/HSETNX'; | ||
import * as HSTRLEN from '../commands/HSTRLEN'; | ||
import * as HTTL from '../commands/HTTL'; | ||
import * as HVALS from '../commands/HVALS'; | ||
@@ -325,2 +335,8 @@ import * as INCR from '../commands/INCR'; | ||
hExists: typeof HEXISTS; | ||
HEXPIRE: typeof HEXPIRE; | ||
hExpire: typeof HEXPIRE; | ||
HEXPIREAT: typeof HEXPIREAT; | ||
hExpireAt: typeof HEXPIREAT; | ||
HEXPIRETIME: typeof HEXPIRETIME; | ||
hExpireTime: typeof HEXPIRETIME; | ||
HGET: typeof HGET; | ||
@@ -340,2 +356,12 @@ hGet: typeof HGET; | ||
hmGet: typeof HMGET; | ||
HPERSIST: typeof HPERSIST; | ||
hPersist: typeof HPERSIST; | ||
HPEXPIRE: typeof HPEXPIRE; | ||
hpExpire: typeof HPEXPIRE; | ||
HPEXPIREAT: typeof HPEXPIREAT; | ||
hpExpireAt: typeof HPEXPIREAT; | ||
HPEXPIRETIME: typeof HPEXPIRETIME; | ||
hpExpireTime: typeof HPEXPIRETIME; | ||
HPTTL: typeof HPTTL; | ||
hpTTL: typeof HPTTL; | ||
HRANDFIELD_COUNT_WITHVALUES: typeof HRANDFIELD_COUNT_WITHVALUES; | ||
@@ -349,2 +375,4 @@ hRandFieldCountWithValues: typeof HRANDFIELD_COUNT_WITHVALUES; | ||
hScan: typeof HSCAN; | ||
HSCAN_NOVALUES: typeof HSCAN_NOVALUES; | ||
hScanNoValues: typeof HSCAN_NOVALUES; | ||
HSET: typeof HSET; | ||
@@ -356,2 +384,4 @@ hSet: typeof HSET; | ||
hStrLen: typeof HSTRLEN; | ||
HTTL: typeof HTTL; | ||
hTTL: typeof HTTL; | ||
HVALS: typeof HVALS; | ||
@@ -358,0 +388,0 @@ hVals: typeof HVALS; |
@@ -57,2 +57,5 @@ "use strict"; | ||
const HEXISTS = require("../commands/HEXISTS"); | ||
const HEXPIRE = require("../commands/HEXPIRE"); | ||
const HEXPIREAT = require("../commands/HEXPIREAT"); | ||
const HEXPIRETIME = require("../commands/HEXPIRETIME"); | ||
const HGET = require("../commands/HGET"); | ||
@@ -65,2 +68,7 @@ const HGETALL = require("../commands/HGETALL"); | ||
const HMGET = require("../commands/HMGET"); | ||
const HPERSIST = require("../commands/HPERSIST"); | ||
const HPEXPIRE = require("../commands/HPEXPIRE"); | ||
const HPEXPIREAT = require("../commands/HPEXPIREAT"); | ||
const HPEXPIRETIME = require("../commands/HPEXPIRETIME"); | ||
const HPTTL = require("../commands/HPTTL"); | ||
const HRANDFIELD_COUNT_WITHVALUES = require("../commands/HRANDFIELD_COUNT_WITHVALUES"); | ||
@@ -70,5 +78,7 @@ const HRANDFIELD_COUNT = require("../commands/HRANDFIELD_COUNT"); | ||
const HSCAN = require("../commands/HSCAN"); | ||
const HSCAN_NOVALUES = require("../commands/HSCAN_NOVALUES"); | ||
const HSET = require("../commands/HSET"); | ||
const HSETNX = require("../commands/HSETNX"); | ||
const HSTRLEN = require("../commands/HSTRLEN"); | ||
const HTTL = require("../commands/HTTL"); | ||
const HVALS = require("../commands/HVALS"); | ||
@@ -327,2 +337,8 @@ const INCR = require("../commands/INCR"); | ||
hExists: HEXISTS, | ||
HEXPIRE, | ||
hExpire: HEXPIRE, | ||
HEXPIREAT, | ||
hExpireAt: HEXPIREAT, | ||
HEXPIRETIME, | ||
hExpireTime: HEXPIRETIME, | ||
HGET, | ||
@@ -342,2 +358,12 @@ hGet: HGET, | ||
hmGet: HMGET, | ||
HPERSIST, | ||
hPersist: HPERSIST, | ||
HPEXPIRE, | ||
hpExpire: HPEXPIRE, | ||
HPEXPIREAT, | ||
hpExpireAt: HPEXPIREAT, | ||
HPEXPIRETIME, | ||
hpExpireTime: HPEXPIRETIME, | ||
HPTTL, | ||
hpTTL: HPTTL, | ||
HRANDFIELD_COUNT_WITHVALUES, | ||
@@ -351,2 +377,4 @@ hRandFieldCountWithValues: HRANDFIELD_COUNT_WITHVALUES, | ||
hScan: HSCAN, | ||
HSCAN_NOVALUES, | ||
hScanNoValues: HSCAN_NOVALUES, | ||
HSET, | ||
@@ -358,2 +386,4 @@ hSet: HSET, | ||
hStrLen: HSTRLEN, | ||
HTTL, | ||
hTTL: HTTL, | ||
HVALS, | ||
@@ -360,0 +390,0 @@ hVals: HVALS, |
@@ -8,3 +8,4 @@ import { RedisCommandArguments } from '.'; | ||
USER = "USER", | ||
SKIP_ME = "SKIPME" | ||
SKIP_ME = "SKIPME", | ||
MAXAGE = "MAXAGE" | ||
} | ||
@@ -32,5 +33,8 @@ interface KillFilter<T extends ClientKillFilters> { | ||
}); | ||
type KillFilters = KillAddress | KillLocalAddress | KillId | KillType | KillUser | KillSkipMe; | ||
interface KillMaxAge extends KillFilter<ClientKillFilters.MAXAGE> { | ||
maxAge: number; | ||
} | ||
type KillFilters = KillAddress | KillLocalAddress | KillId | KillType | KillUser | KillSkipMe | KillMaxAge; | ||
export declare function transformArguments(filters: KillFilters | Array<KillFilters>): RedisCommandArguments; | ||
export declare function transformReply(): number; | ||
export {}; |
@@ -12,2 +12,3 @@ "use strict"; | ||
ClientKillFilters["SKIP_ME"] = "SKIPME"; | ||
ClientKillFilters["MAXAGE"] = "MAXAGE"; | ||
})(ClientKillFilters || (exports.ClientKillFilters = ClientKillFilters = {})); | ||
@@ -54,3 +55,6 @@ function transformArguments(filters) { | ||
break; | ||
case ClientKillFilters.MAXAGE: | ||
args.push(filter.maxAge.toString()); | ||
break; | ||
} | ||
} |
@@ -6,3 +6,3 @@ import { RedisCommandArgument, RedisCommandArguments } from '.'; | ||
export declare function transformArguments(key: RedisCommandArgument, cursor: number, options?: ScanOptions): RedisCommandArguments; | ||
type HScanRawReply = [RedisCommandArgument, Array<RedisCommandArgument>]; | ||
export type HScanRawReply = [RedisCommandArgument, Array<RedisCommandArgument>]; | ||
export interface HScanTuple { | ||
@@ -9,0 +9,0 @@ field: RedisCommandArgument; |
{ | ||
"name": "@redis/client", | ||
"version": "1.5.16", | ||
"version": "1.5.17", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "main": "./dist/index.js", |
{ | ||
"name": "@redis/client", | ||
"version": "1.5.17", | ||
"version": "1.6.0", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "main": "./dist/index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
613566
741
13647