Function mz_storage::source::kinesis::create_state

async fn create_state(
    base_metrics: &KinesisMetrics,
    c: KinesisSourceConnection,
    aws_external_id_prefix: Option<&AwsExternalIdPrefix>,
    source_id: GlobalId,
    secrets_reader: &dyn SecretsReader
) -> Result<(KinesisClient, String, BTreeMap<String, ShardMetrics>, VecDeque<(String, Option<String>)>), Error>

Creates the necessary data-structures for shard management