Struct CreateStreamInput 

#[non_exhaustive]
pub struct CreateStreamInput {
    pub stream_name: Option<String>,
    pub shard_count: Option<i32>,
    pub stream_mode_details: Option<StreamModeDetails>,
    pub tags: Option<HashMap<String, String>>,
    pub warm_throughput_mibps: Option<i32>,
    pub max_record_size_in_kib: Option<i32>,
}

Represents the input for CreateStream.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

stream_name: Option<String>

A name to identify the stream. The stream name is scoped to the Amazon Web Services account used by the application that creates the stream. It is also scoped by Amazon Web Services Region. That is, two streams in two different Amazon Web Services accounts can have the same name. Two streams in the same Amazon Web Services account but in two different Regions can also have the same name.

shard_count: Option<i32>

The number of shards that the stream will use. The throughput of the stream is a function of the number of shards; more shards are required for greater provisioned throughput.

stream_mode_details: Option<StreamModeDetails>

Indicates the capacity mode of the data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand capacity mode and a provisioned capacity mode for your data streams.

tags: Option<HashMap<String, String>>

A set of up to 50 key-value pairs to use to create the tags. A tag consists of a required key and an optional value.

warm_throughput_mibps: Option<i32>

The target warm throughput in MB/s that the stream should be scaled to handle. This represents the throughput capacity that will be immediately available for write operations.

max_record_size_in_kib: Option<i32>

The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.

Implementations

impl CreateStreamInput

pub fn stream_name(&self) -> Option<&str>

A name to identify the stream. The stream name is scoped to the Amazon Web Services account used by the application that creates the stream. It is also scoped by Amazon Web Services Region. That is, two streams in two different Amazon Web Services accounts can have the same name. Two streams in the same Amazon Web Services account but in two different Regions can also have the same name.

pub fn shard_count(&self) -> Option<i32>

The number of shards that the stream will use. The throughput of the stream is a function of the number of shards; more shards are required for greater provisioned throughput.

pub fn stream_mode_details(&self) -> Option<&StreamModeDetails>

Indicates the capacity mode of the data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand capacity mode and a provisioned capacity mode for your data streams.

pub fn tags(&self) -> Option<&HashMap<String, String>>

A set of up to 50 key-value pairs to use to create the tags. A tag consists of a required key and an optional value.

pub fn warm_throughput_mibps(&self) -> Option<i32>

The target warm throughput in MB/s that the stream should be scaled to handle. This represents the throughput capacity that will be immediately available for write operations.

pub fn max_record_size_in_kib(&self) -> Option<i32>

The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.

impl CreateStreamInput

pub fn builder() -> CreateStreamInputBuilder

Creates a new builder-style object to manufacture CreateStreamInput.

Trait Implementations

impl Clone for CreateStreamInput

fn clone(&self) -> CreateStreamInput

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CreateStreamInput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for CreateStreamInput

fn eq(&self, other: &CreateStreamInput) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for CreateStreamInput