#[non_exhaustive]
pub struct StreamDescriptionSummaryBuilder { /* private fields */ }
Expand description

A builder for StreamDescriptionSummary.

Implementations§

source§

impl StreamDescriptionSummaryBuilder

source

pub fn stream_name(self, input: impl Into<String>) -> Self

The name of the stream being described.

This field is required.
source

pub fn set_stream_name(self, input: Option<String>) -> Self

The name of the stream being described.

source

pub fn get_stream_name(&self) -> &Option<String>

The name of the stream being described.

source

pub fn stream_arn(self, input: impl Into<String>) -> Self

The Amazon Resource Name (ARN) for the stream being described.

This field is required.
source

pub fn set_stream_arn(self, input: Option<String>) -> Self

The Amazon Resource Name (ARN) for the stream being described.

source

pub fn get_stream_arn(&self) -> &Option<String>

The Amazon Resource Name (ARN) for the stream being described.

source

pub fn stream_status(self, input: StreamStatus) -> Self

The current status of the stream being described. The stream status is one of the following states:

  • CREATING - The stream is being created. Kinesis Data Streams immediately returns and sets StreamStatus to CREATING.

  • DELETING - The stream is being deleted. The specified stream is in the DELETING state until Kinesis Data Streams completes the deletion.

  • ACTIVE - The stream exists and is ready for read and write operations or deletion. You should perform read and write operations only on an ACTIVE stream.

  • UPDATING - Shards in the stream are being merged or split. Read and write operations continue to work while the stream is in the UPDATING state.

This field is required.
source

pub fn set_stream_status(self, input: Option<StreamStatus>) -> Self

The current status of the stream being described. The stream status is one of the following states:

  • CREATING - The stream is being created. Kinesis Data Streams immediately returns and sets StreamStatus to CREATING.

  • DELETING - The stream is being deleted. The specified stream is in the DELETING state until Kinesis Data Streams completes the deletion.

  • ACTIVE - The stream exists and is ready for read and write operations or deletion. You should perform read and write operations only on an ACTIVE stream.

  • UPDATING - Shards in the stream are being merged or split. Read and write operations continue to work while the stream is in the UPDATING state.

source

pub fn get_stream_status(&self) -> &Option<StreamStatus>

The current status of the stream being described. The stream status is one of the following states:

  • CREATING - The stream is being created. Kinesis Data Streams immediately returns and sets StreamStatus to CREATING.

  • DELETING - The stream is being deleted. The specified stream is in the DELETING state until Kinesis Data Streams completes the deletion.

  • ACTIVE - The stream exists and is ready for read and write operations or deletion. You should perform read and write operations only on an ACTIVE stream.

  • UPDATING - Shards in the stream are being merged or split. Read and write operations continue to work while the stream is in the UPDATING state.

source

pub fn stream_mode_details(self, input: StreamModeDetails) -> Self

Specifies the capacity mode to which you want to set your data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand ycapacity mode and a provisioned capacity mode for your data streams.

source

pub fn set_stream_mode_details(self, input: Option<StreamModeDetails>) -> Self

Specifies the capacity mode to which you want to set your data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand ycapacity mode and a provisioned capacity mode for your data streams.

source

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

Specifies the capacity mode to which you want to set your data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand ycapacity mode and a provisioned capacity mode for your data streams.

source

pub fn retention_period_hours(self, input: i32) -> Self

The current retention period, in hours.

This field is required.
source

pub fn set_retention_period_hours(self, input: Option<i32>) -> Self

The current retention period, in hours.

source

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

The current retention period, in hours.

source

pub fn stream_creation_timestamp(self, input: DateTime) -> Self

The approximate time that the stream was created.

This field is required.
source

pub fn set_stream_creation_timestamp(self, input: Option<DateTime>) -> Self

The approximate time that the stream was created.

source

pub fn get_stream_creation_timestamp(&self) -> &Option<DateTime>

The approximate time that the stream was created.

source

pub fn enhanced_monitoring(self, input: EnhancedMetrics) -> Self

Appends an item to enhanced_monitoring.

To override the contents of this collection use set_enhanced_monitoring.

Represents the current enhanced monitoring settings of the stream.

source

pub fn set_enhanced_monitoring( self, input: Option<Vec<EnhancedMetrics>> ) -> Self

Represents the current enhanced monitoring settings of the stream.

source

pub fn get_enhanced_monitoring(&self) -> &Option<Vec<EnhancedMetrics>>

Represents the current enhanced monitoring settings of the stream.

source

pub fn encryption_type(self, input: EncryptionType) -> Self

The encryption type used. This value is one of the following:

  • KMS

  • NONE

source

pub fn set_encryption_type(self, input: Option<EncryptionType>) -> Self

The encryption type used. This value is one of the following:

  • KMS

  • NONE

source

pub fn get_encryption_type(&self) -> &Option<EncryptionType>

The encryption type used. This value is one of the following:

  • KMS

  • NONE

source

pub fn key_id(self, input: impl Into<String>) -> Self

The GUID for the customer-managed Amazon Web Services KMS key to use for encryption. This value can be a globally unique identifier, a fully specified ARN to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

  • Key ARN example: arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012

  • Alias ARN example: arn:aws:kms:us-east-1:123456789012:alias/MyAliasName

  • Globally unique key ID example: 12345678-1234-1234-1234-123456789012

  • Alias name example: alias/MyAliasName

  • Master key owned by Kinesis Data Streams: alias/aws/kinesis

source

pub fn set_key_id(self, input: Option<String>) -> Self

The GUID for the customer-managed Amazon Web Services KMS key to use for encryption. This value can be a globally unique identifier, a fully specified ARN to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

  • Key ARN example: arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012

  • Alias ARN example: arn:aws:kms:us-east-1:123456789012:alias/MyAliasName

  • Globally unique key ID example: 12345678-1234-1234-1234-123456789012

  • Alias name example: alias/MyAliasName

  • Master key owned by Kinesis Data Streams: alias/aws/kinesis

source

pub fn get_key_id(&self) -> &Option<String>

The GUID for the customer-managed Amazon Web Services KMS key to use for encryption. This value can be a globally unique identifier, a fully specified ARN to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

  • Key ARN example: arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012

  • Alias ARN example: arn:aws:kms:us-east-1:123456789012:alias/MyAliasName

  • Globally unique key ID example: 12345678-1234-1234-1234-123456789012

  • Alias name example: alias/MyAliasName

  • Master key owned by Kinesis Data Streams: alias/aws/kinesis

source

pub fn open_shard_count(self, input: i32) -> Self

The number of open shards in the stream.

This field is required.
source

pub fn set_open_shard_count(self, input: Option<i32>) -> Self

The number of open shards in the stream.

source

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

The number of open shards in the stream.

source

pub fn consumer_count(self, input: i32) -> Self

The number of enhanced fan-out consumers registered with the stream.

source

pub fn set_consumer_count(self, input: Option<i32>) -> Self

The number of enhanced fan-out consumers registered with the stream.

source

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

The number of enhanced fan-out consumers registered with the stream.

source

pub fn build(self) -> Result<StreamDescriptionSummary, BuildError>

Consumes the builder and constructs a StreamDescriptionSummary. This method will fail if any of the following fields are not set:

Trait Implementations§

source§

impl Clone for StreamDescriptionSummaryBuilder

source§

fn clone(&self) -> StreamDescriptionSummaryBuilder

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for StreamDescriptionSummaryBuilder

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for StreamDescriptionSummaryBuilder

source§

fn default() -> StreamDescriptionSummaryBuilder

Returns the “default value” for a type. Read more
source§

impl PartialEq for StreamDescriptionSummaryBuilder

source§

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

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl StructuralPartialEq for StreamDescriptionSummaryBuilder

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more