xgroup_create(
name: KeyT,
groupname: GroupT,
id: StreamIdT = "$",
mkstream: bool = False,
entries_read: Optional[int] = None
) → ResponseT
XGROUP_CREATE(
key: RedisArgument,
group: RedisArgument,
id: RedisArgument,
options?: XGroupCreateOptions
) → Any
xgroupCreate(
key: byte[],
consumer: byte[],
id: byte[],
makeStream: boolean
) → String
xgroupCreate(
key: String,
groupName: String,
makeStream: StreamEntryID id final boolean
) → String
xgroupCreate(
key: String,
groupName: String,
id: StreamEntryID,
makeStream: boolean
) → String
xgroupCreate(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K // name of the consumer group.
) → String // simple-reply true if successful. @since 5.2
xgroupCreate(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K, // name of the consumer group.
args: XGroupCreateArgs
) → String // simple-reply true if successful. @since 5.2
xgroupCreate(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K // name of the consumer group.
) → RedisFuture<String> // simple-reply true if successful. @since 5.2
xgroupCreate(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K, // name of the consumer group.
args: XGroupCreateArgs
) → RedisFuture<String> // simple-reply true if successful. @since 5.2
xgroupCreate(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K // name of the consumer group.
) → Mono<String> // simple-reply true if successful. @since 5.2
xgroupCreate(
streamOffset: StreamOffset<K>, // name of the stream containing the offset to set.
group: K, // name of the consumer group.
args: XGroupCreateArgs
) → Mono<String> // simple-reply true if successful. @since 5.2
XGroupCreate(
ctx: context.Context,
stream: Any,
group: Any,
start: string
) → *StatusCmd
XGroupCreateMkStream(
ctx: context.Context,
stream: Any,
group: Any,
start: string
) → *StatusCmd
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
createStream: bool, // Create the stream if it does not already exist.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
createStream: bool, // Create the stream if it does not already exist.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
createStream: bool, // Create the stream if it does not already exist.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
StreamCreateConsumerGroup(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the group to create.
position: RedisValue?, // The position to begin reading the stream. Defaults to NewMessages.
createStream: bool, // Create the stream if it does not already exist.
flags: CommandFlags // The flags to use for this operation.
) → bool // true if the group was created, false otherwise.
create(
$key: string,
$group: string,
$id: string,
bool $mkStream = false: Any,
?string $entriesRead = null: Any
) → Status
xgroup_create(
key: K,
group: G,
id: ID
) → ()
xgroup_create_mkstream(
key: K,
group: G,
id: ID
) → ()
xgroup_create(
key: K,
group: G,
id: ID
) → ()
xgroup_create_mkstream(
key: K,
group: G,
id: ID
) → ()
