Function mz_aws_util::kinesis::get_shard_iterator
source · [−]pub async fn get_shard_iterator(
client: &Client,
stream_name: &str,
shard_id: &str
) -> Result<Option<String>, SdkError<GetShardIteratorError>>
This is supported on crate feature
kinesis
only.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.