Function mz_kinesis_util::get_shard_iterator
source · pub async fn get_shard_iterator(
client: &Client,
stream_name: &str,
shard_id: &str
) -> Result<Option<String>, SdkError<GetShardIteratorError>>
Expand description
Constructs an iterator over a Kinesis shard.
This function is a wrapper around around the GetShardIterator
API. It
returns the TRIM_HORIZON
shard iterator of a given stream and shard,
meaning it will return the location in the shard with the oldest data
record.
Errors
Any errors from the underlying GetShardIterator
API call are surfaced
directly.