xgroup_delconsumer(
name: KeyT,
groupname: GroupT,
consumername: ConsumerT
) → ResponseT
Possible errors
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xGroupDelConsumer(
key: RedisArgument,
group: RedisArgument,
consumer: RedisArgument
) → NumberReply
Possible errors
- NOGROUP:
SimpleError (test with err.message.startsWith('NOGROUP'))
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroup(
subcommand: "CREATE",
key: RedisKey,
groupname: string | Buffer,
id: string | Buffer | number,
callback?: Callback<unknown>
) → Result<unknown, Context>
xgroup(
subcommand: "CREATE",
key: RedisKey,
groupname: string | Buffer,
id: string | Buffer | number,
entriesReadToken: "ENTRIESREAD",
entriesRead: number | string,
callback?: Callback<unknown>
) → Result<unknown, Context>
xgroup(
subcommand: "CREATE",
key: RedisKey,
groupname: string | Buffer,
id: string | Buffer | number,
mkstream: "MKSTREAM",
callback?: Callback<unknown>
) → Result<unknown, Context>
xgroup(
subcommand: "CREATE",
key: RedisKey,
groupname: string | Buffer,
id: string | Buffer | number,
mkstream: "MKSTREAM",
entriesReadToken: "ENTRIESREAD",
entriesRead: number | string,
callback?: Callback<unknown>
) → Result<unknown, Context>
xgroup(
subcommand: "CREATE",
key: RedisKey,
groupname: string | Buffer,
newId: "$",
callback?: Callback<unknown>
) → Result<unknown, Context>
Possible errors
- NOGROUP:
ReplyError (test with err.message.startsWith('NOGROUP'))
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupDelConsumer(
key: byte[],
groupName: byte[],
consumerName: byte[]
) → long
xgroupDelConsumer(
key: String,
groupName: String,
consumerName: String
) → long
xgroupDelConsumer(
key: String,
groupName: String,
consumerName: String
) → long
Possible errors
- NOGROUP:
JedisDataException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupDelconsumer(
key: K, // the stream key.
consumer: Consumer<K> // consumer identified by group name and consumer key.
) → Long // Long integer-reply number of pending messages.
Possible errors
- NOGROUP:
RedisCommandExecutionException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupDelconsumer(
key: K, // the stream key.
consumer: Consumer<K> // consumer identified by group name and consumer key.
) → RedisFuture<Long> // Long integer-reply number of pending messages.
Possible errors
- NOGROUP:
RedisCommandExecutionException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupDelconsumer(
key: K, // the stream key.
consumer: Consumer<K> // consumer identified by group name and consumer key.
) → Mono<Long> // Long integer-reply number of pending messages.
Possible errors
- NOGROUP:
RedisCommandExecutionException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
XGroupDelConsumer(
ctx: context.Context,
stream: Any,
group: Any,
consumer: string
) → *IntCmd
Possible errors
- NOGROUP:
redis.Error (test with redis.HasErrorPrefix(err, "NOGROUP"))
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
StreamDeleteConsumer(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
consumerName: RedisValue, // The name of the consumer.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages that were pending for the deleted consumer.
Possible errors
- NOGROUP:
RedisServerException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
StreamDeleteConsumerAsync(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
consumerName: RedisValue, // The name of the consumer.
flags: CommandFlags // The flags to use for this operation.
) → Task<long> // The number of messages that were pending for the deleted consumer.
Possible errors
- NOGROUP:
RedisServerException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
delConsumer(
$key: string,
$group: string,
$consumer: string
) → int
Possible errors
- NOGROUP:
Predis\Response\ServerException (test with $e->getErrorType() === 'NOGROUP')
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroup(
key: String, // the stream key
group: String, // the consumer group name
consumer: String // the consumer name
) → Integer // effected count
Possible errors
- NOGROUP:
Redis::CommandError
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroup_delconsumer(
key: K,
group: G,
consumer: C
) → usize
Possible errors
- NOGROUP:
ErrorKind::Extension (test with err.code() == Some("NOGROUP"))
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroup_delconsumer(
key: K,
group: G,
consumer: C
) → usize
Possible errors
- NOGROUP:
ErrorKind::Extension (test with err.code() == Some("NOGROUP"))
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
