Class KinesisShardOffset
java.lang.Object
org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
A model to represent a sequence in the shard for particular
ShardIteratorType
.- Since:
- 1.1
- Author:
- Artem Bilan
-
Constructor Summary
ConstructorsConstructorDescriptionKinesisShardOffset
(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType) -
Method Summary
Modifier and TypeMethodDescriptionstatic KinesisShardOffset
afterSequenceNumber
(String sequenceNumber) static KinesisShardOffset
afterSequenceNumber
(String stream, String shard, String sequenceNumber) static KinesisShardOffset
atSequenceNumber
(String sequenceNumber) static KinesisShardOffset
atSequenceNumber
(String stream, String shard, String sequenceNumber) static KinesisShardOffset
atTimestamp
(String stream, String shard, Instant timestamp) static KinesisShardOffset
atTimestamp
(Instant timestamp) boolean
software.amazon.awssdk.services.kinesis.model.ShardIteratorType
getShard()
int
hashCode()
boolean
isReset()
static KinesisShardOffset
latest()
static KinesisShardOffset
reset()
void
setIteratorType
(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType) void
setReset
(boolean reset) void
setSequenceNumber
(String sequenceNumber) void
void
void
setTimestamp
(Instant timestamp) software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest
toString()
static KinesisShardOffset
static KinesisShardOffset
trimHorizon
(String stream, String shard)
-
Constructor Details
-
KinesisShardOffset
public KinesisShardOffset(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType) -
KinesisShardOffset
-
-
Method Details
-
setIteratorType
public void setIteratorType(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType) -
getIteratorType
public software.amazon.awssdk.services.kinesis.model.ShardIteratorType getIteratorType() -
setSequenceNumber
-
setTimestamp
-
setStream
-
setShard
-
setReset
public void setReset(boolean reset) -
getSequenceNumber
-
getTimestamp
-
getStream
-
getShard
-
isReset
public boolean isReset() -
reset
-
toShardIteratorRequest
public software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest toShardIteratorRequest() -
equals
-
hashCode
public int hashCode() -
toString
-
latest
-
latest
-
trimHorizon
-
trimHorizon
-
atSequenceNumber
-
atSequenceNumber
public static KinesisShardOffset atSequenceNumber(String stream, String shard, String sequenceNumber) -
afterSequenceNumber
-
afterSequenceNumber
public static KinesisShardOffset afterSequenceNumber(String stream, String shard, String sequenceNumber) -
atTimestamp
-
atTimestamp
-