Package io.lettuce.core
Class XReadArgs.StreamOffset<K>
- java.lang.Object
-
- io.lettuce.core.XReadArgs.StreamOffset<K>
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <K> XReadArgs.StreamOffset<K>
from(K name, String offset)
Read all arriving elements from the stream identified byname
starting atoffset
.K
getName()
String
getOffset()
static <K> XReadArgs.StreamOffset<K>
lastConsumed(K name)
Read all new arriving elements from the stream identified byname
with ids greater than the last one consumed by the consumer group.static <K> XReadArgs.StreamOffset<K>
latest(K name)
Read all new arriving elements from the stream identified byname
.String
toString()
-
-
-
Method Detail
-
latest
public static <K> XReadArgs.StreamOffset<K> latest(K name)
Read all new arriving elements from the stream identified byname
.- Parameters:
name
- must not benull
.- Returns:
- the
XReadArgs.StreamOffset
object without a specific offset.
-
lastConsumed
public static <K> XReadArgs.StreamOffset<K> lastConsumed(K name)
Read all new arriving elements from the stream identified byname
with ids greater than the last one consumed by the consumer group.- Parameters:
name
- must not benull
.- Returns:
- the
XReadArgs.StreamOffset
object without a specific offset.
-
from
public static <K> XReadArgs.StreamOffset<K> from(K name, String offset)
Read all arriving elements from the stream identified byname
starting atoffset
.- Parameters:
name
- must not benull
.offset
- the stream offset.- Returns:
- the
XReadArgs.StreamOffset
object without a specific offset.
-
getName
public K getName()
-
getOffset
public String getOffset()
-
-