Package redis.clients.jedis.commands

Interface StreamBinaryCommands

All Known Subinterfaces:

JedisBinaryCommands

All Known Implementing Classes:

Jedis, JedisCluster, JedisPooled, JedisSentineled, JedisSharding, UnifiedJedis

public interface StreamBinaryCommands

Method Summary

Modifier and Type	Method	Description
long	xack(byte[] key, byte[] group, byte[]... ids)
default byte[]	xadd(byte[] key, Map<byte[],byte[]> hash, XAddParams params)
byte[]	xadd(byte[] key, XAddParams params, Map<byte[],byte[]> hash)
List<Object>	xautoclaim(byte[] key, byte[] groupName, byte[] consumerName, long minIdleTime, byte[] start, XAutoClaimParams params)
List<Object>	xautoclaimJustId(byte[] key, byte[] groupName, byte[] consumerName, long minIdleTime, byte[] start, XAutoClaimParams params)
List<byte[]>	xclaim(byte[] key, byte[] group, byte[] consumerName, long minIdleTime, XClaimParams params, byte[]... ids)
List<byte[]>	xclaimJustId(byte[] key, byte[] group, byte[] consumerName, long minIdleTime, XClaimParams params, byte[]... ids)
long	xdel(byte[] key, byte[]... ids)
String	xgroupCreate(byte[] key, byte[] groupName, byte[] id, boolean makeStream)
boolean	xgroupCreateConsumer(byte[] key, byte[] groupName, byte[] consumerName)
long	xgroupDelConsumer(byte[] key, byte[] groupName, byte[] consumerName)
long	xgroupDestroy(byte[] key, byte[] groupName)
String	xgroupSetID(byte[] key, byte[] groupName, byte[] id)
List<Object>	xinfoConsumers(byte[] key, byte[] group)
List<Object>	xinfoGroup(byte[] key)	Deprecated. Use xinfoGroups(byte[]).
List<Object>	xinfoGroups(byte[] key)
Object	xinfoStream(byte[] key)
Object	xinfoStreamFull(byte[] key)	Introspection command used in order to retrieve all information about the stream
Object	xinfoStreamFull(byte[] key, int count)	Introspection command used in order to retrieve all information about the stream
long	xlen(byte[] key)
Object	xpending(byte[] key, byte[] groupName)
List<Object>	xpending(byte[] key, byte[] groupName, byte[] start, byte[] end, int count, byte[] consumerName)	Deprecated. Use xpending(byte[], byte[], redis.clients.jedis.params.XPendingParams).
List<Object>	xpending(byte[] key, byte[] groupName, XPendingParams params)
List<Object>	xrange(byte[] key, byte[] start, byte[] end)
List<Object>	xrange(byte[] key, byte[] start, byte[] end, int count)
List<Object>	xread(XReadParams xReadParams, Map.Entry<byte[],byte[]>... streams)
List<Object>	xreadGroup(byte[] groupName, byte[] consumer, XReadGroupParams xReadGroupParams, Map.Entry<byte[],byte[]>... streams)
List<Object>	xrevrange(byte[] key, byte[] end, byte[] start)
List<Object>	xrevrange(byte[] key, byte[] end, byte[] start, int count)
long	xtrim(byte[] key, long maxLen, boolean approximateLength)
long	xtrim(byte[] key, XTrimParams params)

Method Details

xadd

default byte[] xadd(byte[] key,
 Map<byte[],byte[]> hash,
 XAddParams params)

xadd

byte[] xadd(byte[] key,
 XAddParams params,
 Map<byte[],byte[]> hash)

xlen

long xlen(byte[] key)

xrange

List<Object> xrange(byte[] key,
 byte[] start,
 byte[] end)

xrange

List<Object> xrange(byte[] key,
 byte[] start,
 byte[] end,
 int count)

xrevrange

List<Object> xrevrange(byte[] key,
 byte[] end,
 byte[] start)

xrevrange

List<Object> xrevrange(byte[] key,
 byte[] end,
 byte[] start,
 int count)

xack

long xack(byte[] key,
 byte[] group,
 byte[]... ids)

xgroupCreate

String xgroupCreate(byte[] key,
 byte[] groupName,
 byte[] id,
 boolean makeStream)

xgroupSetID

String xgroupSetID(byte[] key,
 byte[] groupName,
 byte[] id)

xgroupDestroy

long xgroupDestroy(byte[] key,
 byte[] groupName)

xgroupCreateConsumer

boolean xgroupCreateConsumer(byte[] key,
 byte[] groupName,
 byte[] consumerName)

xgroupDelConsumer

long xgroupDelConsumer(byte[] key,
 byte[] groupName,
 byte[] consumerName)

xdel

long xdel(byte[] key,
 byte[]... ids)

xtrim

long xtrim(byte[] key,
 long maxLen,
 boolean approximateLength)

xtrim

long xtrim(byte[] key,
 XTrimParams params)

xpending

Object xpending(byte[] key,
 byte[] groupName)

xpending

@Deprecated
List<Object> xpending(byte[] key,
 byte[] groupName,
 byte[] start,
 byte[] end,
 int count,
 byte[] consumerName)

Deprecated.

Use xpending(byte[], byte[], redis.clients.jedis.params.XPendingParams).

xpending

List<Object> xpending(byte[] key,
 byte[] groupName,
 XPendingParams params)

xclaim

List<byte[]> xclaim(byte[] key,
 byte[] group,
 byte[] consumerName,
 long minIdleTime,
 XClaimParams params,
 byte[]... ids)

xclaimJustId

List<byte[]> xclaimJustId(byte[] key,
 byte[] group,
 byte[] consumerName,
 long minIdleTime,
 XClaimParams params,
 byte[]... ids)

xautoclaim

List<Object> xautoclaim(byte[] key,
 byte[] groupName,
 byte[] consumerName,
 long minIdleTime,
 byte[] start,
 XAutoClaimParams params)

xautoclaimJustId

List<Object> xautoclaimJustId(byte[] key,
 byte[] groupName,
 byte[] consumerName,
 long minIdleTime,
 byte[] start,
 XAutoClaimParams params)

xinfoStream

Object xinfoStream(byte[] key)

xinfoStreamFull

Object xinfoStreamFull(byte[] key)

Introspection command used in order to retrieve all information about the stream

Parameters:

key - Stream name

xinfoStreamFull

Object xinfoStreamFull(byte[] key,
 int count)

Introspection command used in order to retrieve all information about the stream

Parameters:

key - Stream name

count - stream info count

xinfoGroup

@Deprecated
List<Object> xinfoGroup(byte[] key)

Deprecated.

Use xinfoGroups(byte[]).

xinfoGroups

List<Object> xinfoGroups(byte[] key)

xinfoConsumers

List<Object> xinfoConsumers(byte[] key,
 byte[] group)

xread

List<Object> xread(XReadParams xReadParams,
 Map.Entry<byte[],byte[]>... streams)

xreadGroup

List<Object> xreadGroup(byte[] groupName,
 byte[] consumer,
 XReadGroupParams xReadGroupParams,
 Map.Entry<byte[],byte[]>... streams)