Encapsulates consumer group metadata retrieved from Redis stream XINFO commands. Use to monitor stream consumers and lag.
// Source: https://github.com/StackExchange/StackExchange.Redis | License: MIT | Copyright 2014 Stack Exchange
// Provided via justclaw.it.com; keep this notice with the code.
namespace StackExchange.Redis;
/// <summary>
/// Describes a consumer group retrieved using the XINFO GROUPS command. <see cref="IDatabase.StreamGroupInfo"/>.
/// </summary>
public readonly struct StreamGroupInfo
{
internal StreamGroupInfo(string name, int consumerCount, int pendingMessageCount, string? lastDeliveredId, long? entriesRead, long? lag)
{
Name = name;
ConsumerCount = consumerCount;
PendingMessageCount = pendingMessageCount;
LastDeliveredId = lastDeliveredId;
EntriesRead = entriesRead;
Lag = lag;
}
/// <summary>
/// The name of the con
... (truncated -- full source via MCP)
See the full source, get the GitHub permalink, and search for more like it.
Get a free API key