XPENDING - Upstash Documentation

Arguments#

keystringrequired#

The key of the stream.

groupstringrequired#

The consumer group name.

startstringrequired#

The minimum pending ID to return. Use ”-” for the first available ID.

endstringrequired#

The maximum pending ID to return. Use ”+” for the last available ID.

countnumberrequired#

The maximum number of pending messages to return.

options#

Show properties

idleTimenumber#

Filter by minimum idle time in milliseconds.

consumerstring#

Filter results by a specific consumer.

Response#

Returns an array of pending message details.

XLEN XRANGE

const result = await redis.xpending("mystream", "mygroup", "-", "+", 10);

const result = await redis.xpending("mystream", "mygroup", "-", "+", 5, {  idleTime: 10000});

const result = await redis.xpending("mystream", "mygroup", "-", "+", 5, {  consumer: "consumer1"});

[  2, // total pending count  "1638360173533-0", // smallest pending ID  "1638360173533-1", // greatest pending ID  [    ["consumer1", "1"], // consumer and their pending count    ["consumer2", "1"]  ]]