Package redis.clients.jedis.commands

Interface StreamPipelineBinaryCommands

All Known Subinterfaces:

PipelineBinaryCommands

All Known Implementing Classes:

ClusterPipeline, MultiNodePipelineBase, Pipeline, ReliableTransaction, ShardedPipeline, Transaction, TransactionBase

public interface StreamPipelineBinaryCommands

Method Summary

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

Method Details

xadd

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

xadd

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

xlen

Response<Long> xlen(byte[] key)

xrange

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

xrange

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

xrevrange

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

xrevrange

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

xack

Response<Long> xack(byte[] key,
 byte[] group,
 byte[]... ids)

xgroupCreate

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

xgroupSetID

Response<String> xgroupSetID(byte[] key,
 byte[] groupName,
 byte[] id)

xgroupDestroy

Response<Long> xgroupDestroy(byte[] key,
 byte[] groupName)

xgroupCreateConsumer

Response<Boolean> xgroupCreateConsumer(byte[] key,
 byte[] groupName,
 byte[] consumerName)

xgroupDelConsumer

Response<Long> xgroupDelConsumer(byte[] key,
 byte[] groupName,
 byte[] consumerName)

xdel

Response<Long> xdel(byte[] key,
 byte[]... ids)

xtrim

Response<Long> xtrim(byte[] key,
 long maxLen,
 boolean approximateLength)

xtrim

Response<Long> xtrim(byte[] key,
 XTrimParams params)

xpending

Response<Object> xpending(byte[] key,
 byte[] groupName)

xpending

@Deprecated
Response<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

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

xclaim

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

xclaimJustId

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

xautoclaim

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

xautoclaimJustId

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

xinfoStream

Response<Object> xinfoStream(byte[] key)

xinfoStreamFull

Response<Object> xinfoStreamFull(byte[] key)

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

Parameters:

key - Stream name

xinfoStreamFull

Response<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
Response<List<Object>> xinfoGroup(byte[] key)

Deprecated.

Use xinfoGroups(byte[]).

xinfoGroups

Response<List<Object>> xinfoGroups(byte[] key)

xinfoConsumers

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

xread

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

xreadGroup

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