Class KinesisShardOffset

java.lang.Object
org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset

public class KinesisShardOffset extends Object
A model to represent a sequence in the shard for particular ShardIteratorType.
Since:
1.1
Author:
Artem Bilan
  • Constructor Details

    • KinesisShardOffset

      public KinesisShardOffset(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType)
    • KinesisShardOffset

      public KinesisShardOffset(KinesisShardOffset other)
  • 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

      public void setSequenceNumber(String sequenceNumber)
    • setTimestamp

      public void setTimestamp(Instant timestamp)
    • setStream

      public void setStream(String stream)
    • setShard

      public void setShard(String shard)
    • setReset

      public void setReset(boolean reset)
    • getSequenceNumber

      public String getSequenceNumber()
    • getTimestamp

      public Instant getTimestamp()
    • getStream

      public String getStream()
    • getShard

      public String getShard()
    • isReset

      public boolean isReset()
    • reset

      public KinesisShardOffset reset()
    • toShardIteratorRequest

      public software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest toShardIteratorRequest()
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • latest

      public static KinesisShardOffset latest()
    • latest

      public static KinesisShardOffset latest(String stream, String shard)
    • trimHorizon

      public static KinesisShardOffset trimHorizon()
    • trimHorizon

      public static KinesisShardOffset trimHorizon(String stream, String shard)
    • atSequenceNumber

      public static KinesisShardOffset atSequenceNumber(String sequenceNumber)
    • atSequenceNumber

      public static KinesisShardOffset atSequenceNumber(String stream, String shard, String sequenceNumber)
    • afterSequenceNumber

      public static KinesisShardOffset afterSequenceNumber(String sequenceNumber)
    • afterSequenceNumber

      public static KinesisShardOffset afterSequenceNumber(String stream, String shard, String sequenceNumber)
    • atTimestamp

      public static KinesisShardOffset atTimestamp(Instant timestamp)
    • atTimestamp

      public static KinesisShardOffset atTimestamp(String stream, String shard, Instant timestamp)