Class KinesisShardOffset

java.lang.Object

io.awspring.cloud.kinesis.integration.KinesisShardOffset

public class KinesisShardOffset
extends Object

A model to represent a sequence in the shard for particular ShardIteratorType.

Since:

4.0

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor	Description
KinesisShardOffset(KinesisShardOffset other)
KinesisShardOffset(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType)

Method Summary

Modifier and Type	Method	Description
static 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	equals(Object o)
software.amazon.awssdk.services.kinesis.model.ShardIteratorType	getIteratorType()
String	getSequenceNumber()
String	getShard()
String	getStream()
Instant	getTimestamp()
int	hashCode()
boolean	isReset()
static KinesisShardOffset	latest()
static KinesisShardOffset	latest(String stream, String shard)
KinesisShardOffset	reset()
void	setIteratorType(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType)
void	setReset(boolean reset)
void	setSequenceNumber(String sequenceNumber)
void	setShard(String shard)
void	setStream(String stream)
void	setTimestamp(Instant timestamp)
software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest	toShardIteratorRequest()
String	toString()
static KinesisShardOffset	trimHorizon()
static KinesisShardOffset	trimHorizon(String stream, String shard)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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)