Function mz_kinesis_util::get_shard_ids
source · pub async fn get_shard_ids(
client: &Client,
stream_name: &str
) -> Result<impl Iterator<Item = String>, SdkError<ListShardsError>>
Expand description
Gets the shard IDs of the named Kinesis stream.
This function is like list_shards
, but
Errors
Any errors from the underlying GetShardIterator
API call are surfaced
directly.