Uses of Class
redis.clients.jedis.resps.StreamEntry

Packages that use StreamEntry

Package	Description
redis.clients.jedis
redis.clients.jedis.commands	This package contains the interfaces that contain methods representing Redis core commands.
redis.clients.jedis.resps	This package contains custom responses of core Redis commands.

Uses of StreamEntry in redis.clients.jedis

Fields in redis.clients.jedis with type parameters of type StreamEntry

Modifier and Type	Field	Description
static final Builder<Map.Entry<StreamEntryID,List<StreamEntry>>>	BuilderFactory.STREAM_AUTO_CLAIM_RESPONSE
static final Builder<StreamEntry>	BuilderFactory.STREAM_ENTRY
static final Builder<List<StreamEntry>>	BuilderFactory.STREAM_ENTRY_LIST
static final Builder<List<Map.Entry<String,List<StreamEntry>>>>	BuilderFactory.STREAM_READ_RESPONSE

Methods in redis.clients.jedis that return types with arguments of type StreamEntry

Modifier and Type	Method	Description
final CommandObject<Map.Entry<StreamEntryID,List<StreamEntry>>>	CommandObjects.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)
Map.Entry<StreamEntryID,List<StreamEntry>>	Jedis.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)
Response<Map.Entry<StreamEntryID,List<StreamEntry>>>	MultiNodePipelineBase.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)
Response<Map.Entry<StreamEntryID,List<StreamEntry>>>	Pipeline.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)
Response<Map.Entry<StreamEntryID,List<StreamEntry>>>	TransactionBase.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)
Map.Entry<StreamEntryID,List<StreamEntry>>	UnifiedJedis.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)
final CommandObject<List<StreamEntry>>	CommandObjects.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)
List<StreamEntry>	Jedis.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)
Response<List<StreamEntry>>	MultiNodePipelineBase.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)
Response<List<StreamEntry>>	Pipeline.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)
Response<List<StreamEntry>>	TransactionBase.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)
List<StreamEntry>	UnifiedJedis.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)
final CommandObject<List<StreamEntry>>	CommandObjects.xrange(String key, String start, String end)
final CommandObject<List<StreamEntry>>	CommandObjects.xrange(String key, String start, String end, int count)
final CommandObject<List<StreamEntry>>	CommandObjects.xrange(String key, StreamEntryID start, StreamEntryID end)
final CommandObject<List<StreamEntry>>	CommandObjects.xrange(String key, StreamEntryID start, StreamEntryID end, int count)
List<StreamEntry>	Jedis.xrange(String key, String start, String end)
List<StreamEntry>	Jedis.xrange(String key, String start, String end, int count)
List<StreamEntry>	Jedis.xrange(String key, StreamEntryID start, StreamEntryID end)
List<StreamEntry>	Jedis.xrange(String key, StreamEntryID start, StreamEntryID end, int count)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrange(String key, String start, String end)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrange(String key, String start, String end, int count)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrange(String key, StreamEntryID start, StreamEntryID end)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrange(String key, StreamEntryID start, StreamEntryID end, int count)
Response<List<StreamEntry>>	Pipeline.xrange(String key, String start, String end)
Response<List<StreamEntry>>	Pipeline.xrange(String key, String start, String end, int count)
Response<List<StreamEntry>>	Pipeline.xrange(String key, StreamEntryID start, StreamEntryID end)
Response<List<StreamEntry>>	Pipeline.xrange(String key, StreamEntryID start, StreamEntryID end, int count)
Response<List<StreamEntry>>	TransactionBase.xrange(String key, String start, String end)
Response<List<StreamEntry>>	TransactionBase.xrange(String key, String start, String end, int count)
Response<List<StreamEntry>>	TransactionBase.xrange(String key, StreamEntryID start, StreamEntryID end)
Response<List<StreamEntry>>	TransactionBase.xrange(String key, StreamEntryID start, StreamEntryID end, int count)
List<StreamEntry>	UnifiedJedis.xrange(String key, String start, String end)
List<StreamEntry>	UnifiedJedis.xrange(String key, String start, String end, int count)
List<StreamEntry>	UnifiedJedis.xrange(String key, StreamEntryID start, StreamEntryID end)
List<StreamEntry>	UnifiedJedis.xrange(String key, StreamEntryID start, StreamEntryID end, int count)
final CommandObject<List<Map.Entry<String,List<StreamEntry>>>>	CommandObjects.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)
List<Map.Entry<String,List<StreamEntry>>>	Jedis.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)
Response<List<Map.Entry<String,List<StreamEntry>>>>	MultiNodePipelineBase.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)
Response<List<Map.Entry<String,List<StreamEntry>>>>	Pipeline.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)
Response<List<Map.Entry<String,List<StreamEntry>>>>	TransactionBase.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)
List<Map.Entry<String,List<StreamEntry>>>	UnifiedJedis.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)
final CommandObject<List<Map.Entry<String,List<StreamEntry>>>>	CommandObjects.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)
List<Map.Entry<String,List<StreamEntry>>>	Jedis.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)
Response<List<Map.Entry<String,List<StreamEntry>>>>	MultiNodePipelineBase.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)
Response<List<Map.Entry<String,List<StreamEntry>>>>	Pipeline.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)
Response<List<Map.Entry<String,List<StreamEntry>>>>	TransactionBase.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)
List<Map.Entry<String,List<StreamEntry>>>	UnifiedJedis.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)
final CommandObject<List<StreamEntry>>	CommandObjects.xrevrange(String key, String end, String start)
final CommandObject<List<StreamEntry>>	CommandObjects.xrevrange(String key, String end, String start, int count)
final CommandObject<List<StreamEntry>>	CommandObjects.xrevrange(String key, StreamEntryID end, StreamEntryID start)
final CommandObject<List<StreamEntry>>	CommandObjects.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)
List<StreamEntry>	Jedis.xrevrange(String key, String end, String start)
List<StreamEntry>	Jedis.xrevrange(String key, String end, String start, int count)
List<StreamEntry>	Jedis.xrevrange(String key, StreamEntryID end, StreamEntryID start)
List<StreamEntry>	Jedis.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrevrange(String key, String end, String start)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrevrange(String key, String end, String start, int count)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrevrange(String key, StreamEntryID end, StreamEntryID start)
Response<List<StreamEntry>>	MultiNodePipelineBase.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)
Response<List<StreamEntry>>	Pipeline.xrevrange(String key, String end, String start)
Response<List<StreamEntry>>	Pipeline.xrevrange(String key, String end, String start, int count)
Response<List<StreamEntry>>	Pipeline.xrevrange(String key, StreamEntryID end, StreamEntryID start)
Response<List<StreamEntry>>	Pipeline.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)
Response<List<StreamEntry>>	TransactionBase.xrevrange(String key, String end, String start)
Response<List<StreamEntry>>	TransactionBase.xrevrange(String key, String end, String start, int count)
Response<List<StreamEntry>>	TransactionBase.xrevrange(String key, StreamEntryID end, StreamEntryID start)
Response<List<StreamEntry>>	TransactionBase.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)
List<StreamEntry>	UnifiedJedis.xrevrange(String key, String end, String start)
List<StreamEntry>	UnifiedJedis.xrevrange(String key, String end, String start, int count)
List<StreamEntry>	UnifiedJedis.xrevrange(String key, StreamEntryID end, StreamEntryID start)
List<StreamEntry>	UnifiedJedis.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)

Uses of StreamEntry in redis.clients.jedis.commands

Methods in redis.clients.jedis.commands that return types with arguments of type StreamEntry

Modifier and Type	Method	Description
Map.Entry<StreamEntryID,List<StreamEntry>>	StreamCommands.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)	XAUTOCLAIM key group consumer min-idle-time start [COUNT count]
Response<Map.Entry<StreamEntryID,List<StreamEntry>>>	StreamPipelineCommands.xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params)	XAUTOCLAIM key group consumer min-idle-time start [COUNT count]
List<StreamEntry>	StreamCommands.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)	XCLAIM key group consumer min-idle-time <ID-1> ... <ID-N> [IDLE <milliseconds>] [TIME <mstime>] [RETRYCOUNT <count>] [FORCE]
Response<List<StreamEntry>>	StreamPipelineCommands.xclaim(String key, String group, String consumerName, long minIdleTime, XClaimParams params, StreamEntryID... ids)	XCLAIM key group consumer min-idle-time <ID-1> ... <ID-N> [IDLE <milliseconds>] [TIME <mstime>] [RETRYCOUNT <count>] [FORCE]
List<StreamEntry>	StreamCommands.xrange(String key, String start, String end)
List<StreamEntry>	StreamCommands.xrange(String key, String start, String end, int count)
List<StreamEntry>	StreamCommands.xrange(String key, StreamEntryID start, StreamEntryID end)	XRANGE key start end
List<StreamEntry>	StreamCommands.xrange(String key, StreamEntryID start, StreamEntryID end, int count)	XRANGE key start end COUNT count
Response<List<StreamEntry>>	StreamPipelineCommands.xrange(String key, String start, String end)
Response<List<StreamEntry>>	StreamPipelineCommands.xrange(String key, String start, String end, int count)
Response<List<StreamEntry>>	StreamPipelineCommands.xrange(String key, StreamEntryID start, StreamEntryID end)	XRANGE key start end
Response<List<StreamEntry>>	StreamPipelineCommands.xrange(String key, StreamEntryID start, StreamEntryID end, int count)	XRANGE key start end COUNT count
List<Map.Entry<String,List<StreamEntry>>>	StreamCommands.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)	XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
Response<List<Map.Entry<String,List<StreamEntry>>>>	StreamPipelineCommands.xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)	XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
List<Map.Entry<String,List<StreamEntry>>>	StreamCommands.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)	XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
Response<List<Map.Entry<String,List<StreamEntry>>>>	StreamPipelineCommands.xreadGroup(String groupName, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)	XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
List<StreamEntry>	StreamCommands.xrevrange(String key, String end, String start)
List<StreamEntry>	StreamCommands.xrevrange(String key, String end, String start, int count)
List<StreamEntry>	StreamCommands.xrevrange(String key, StreamEntryID end, StreamEntryID start)	XREVRANGE key end start
List<StreamEntry>	StreamCommands.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)	XREVRANGE key end start COUNT count
Response<List<StreamEntry>>	StreamPipelineCommands.xrevrange(String key, String end, String start)
Response<List<StreamEntry>>	StreamPipelineCommands.xrevrange(String key, String end, String start, int count)
Response<List<StreamEntry>>	StreamPipelineCommands.xrevrange(String key, StreamEntryID end, StreamEntryID start)	XREVRANGE key end start
Response<List<StreamEntry>>	StreamPipelineCommands.xrevrange(String key, StreamEntryID end, StreamEntryID start, int count)	XREVRANGE key end start COUNT count

Uses of StreamEntry in redis.clients.jedis.resps

Fields in redis.clients.jedis.resps declared as StreamEntry

Modifier and Type	Field	Description
private final StreamEntry	StreamInfo.firstEntry
private final StreamEntry	StreamInfo.lastEntry

Fields in redis.clients.jedis.resps with type parameters of type StreamEntry

Modifier and Type	Field	Description
private final List<StreamEntry>	StreamFullInfo.entries

Methods in redis.clients.jedis.resps that return StreamEntry

Modifier and Type	Method	Description
StreamEntry	StreamInfo.getFirstEntry()
StreamEntry	StreamInfo.getLastEntry()

Methods in redis.clients.jedis.resps that return types with arguments of type StreamEntry

Modifier and Type	Method	Description
List<StreamEntry>	StreamFullInfo.getEntries()