xgroup_setid(
name: KeyT,
groupname: GroupT,
id: StreamIdT,
entries_read: Optional[int] = None
) → ResponseT
Possible errors
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xGroupSetId(
key: RedisArgument,
group: RedisArgument,
id: RedisArgument,
options?: XGroupSetIdOptions
) → SimpleStringReply<'OK'>
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.
xgroupSetID(
key: byte[],
consumer: byte[],
id: byte[]
) → String
xgroupSetID(
key: String,
groupName: String,
id: StreamEntryID
) → String
xgroupSetID(
key: String,
groupName: String,
id: StreamEntryID
) → String
Possible errors
- NOGROUP:
JedisDataException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupSetid(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K // name of the consumer group.
) → String // simple-reply OK.
Possible errors
- NOGROUP:
RedisCommandExecutionException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupSetid(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K // name of the consumer group.
) → RedisFuture<String> // simple-reply OK.
Possible errors
- NOGROUP:
RedisCommandExecutionException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroupSetid(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K // name of the consumer group.
) → Mono<String> // simple-reply OK.
Possible errors
- NOGROUP:
RedisCommandExecutionException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
XGroupSetID(
ctx: context.Context,
stream: Any,
group: Any,
start: string
) → *StatusCmd
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.
StreamConsumerGroupSetPosition(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
position: RedisValue, // The position from which to read for the consumer group.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if successful, false otherwise.
StreamConsumerGroupSetPosition(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
position: RedisValue, // The position from which to read for the consumer group.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if successful, false otherwise.
Possible errors
- NOGROUP:
RedisServerException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
StreamConsumerGroupSetPositionAsync(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
position: RedisValue, // The position from which to read for the consumer group.
flags: CommandFlags // The flags to use for this operation.
) → Task<bool> // true if successful, false otherwise.
StreamConsumerGroupSetPositionAsync(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
position: RedisValue, // The position from which to read for the consumer group.
flags: CommandFlags // The flags to use for this operation.
) → Task<bool> // true if successful, false otherwise.
Possible errors
- NOGROUP:
RedisServerException
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
setId(
$key: string,
$group: string,
$id: string,
?string $entriesRead = null: Any
) → Status
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
id_or_consumer: String // the entry id or $
) → String // OK
Possible errors
- NOGROUP:
Redis::CommandError
See Redis error messages for what each error means. Other errors, such as connection errors, aren't listed.
xgroup_setid(
key: K,
group: G,
id: ID
) → ()
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_setid(
key: K,
group: G,
id: ID
) → ()
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.
