Skip to content

MergeShardsInput

Source code in docs_src/capo_kinesis/types/merge_shards_input.py 
16
17
18
19
20
21
22
23
24
25
26
class MergeShardsInput(TypedDict, closed=True):
    stream_name: NotRequired["capo_kinesis.types.stream_name.StreamName"]
    """<p>The name of the stream for the merge.</p>"""
    shard_to_merge: "capo_kinesis.types.shard_id.ShardId"
    """<p>The shard ID of the shard to combine with the adjacent shard for the merge.</p>"""
    adjacent_shard_to_merge: "capo_kinesis.types.shard_id.ShardId"
    """<p>The shard ID of the adjacent shard for the merge.</p>"""
    stream_arn: NotRequired["capo_kinesis.types.stream_arn.StreamARN"]
    """<p>The ARN of the stream.</p>"""
    stream_id: NotRequired["capo_kinesis.types.stream_id.StreamId"]
    """<p>Not Implemented. Reserved for future use.</p>"""

adjacent_shard_to_merge instance-attribute 

adjacent_shard_to_merge: ShardId

The shard ID of the adjacent shard for the merge.

shard_to_merge instance-attribute 

shard_to_merge: ShardId

The shard ID of the shard to combine with the adjacent shard for the merge.

stream_arn instance-attribute 

stream_arn: NotRequired[StreamARN]

The ARN of the stream.

stream_id instance-attribute 

stream_id: NotRequired[StreamId]

Not Implemented. Reserved for future use.

stream_name instance-attribute 

stream_name: NotRequired[StreamName]

The name of the stream for the merge.