Struct aws_sdk_qldb::types::builders::KinesisConfigurationBuilder
source · #[non_exhaustive]pub struct KinesisConfigurationBuilder { /* private fields */ }Expand description
A builder for KinesisConfiguration.
Implementations§
source§impl KinesisConfigurationBuilder
impl KinesisConfigurationBuilder
sourcepub fn stream_arn(self, input: impl Into<String>) -> Self
pub fn stream_arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) of the Kinesis Data Streams resource.
This field is required.sourcepub fn set_stream_arn(self, input: Option<String>) -> Self
pub fn set_stream_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) of the Kinesis Data Streams resource.
sourcepub fn get_stream_arn(&self) -> &Option<String>
pub fn get_stream_arn(&self) -> &Option<String>
The Amazon Resource Name (ARN) of the Kinesis Data Streams resource.
sourcepub fn aggregation_enabled(self, input: bool) -> Self
pub fn aggregation_enabled(self, input: bool) -> Self
Enables QLDB to publish multiple data records in a single Kinesis Data Streams record, increasing the number of records sent per API call.
Default: True
Record aggregation has important implications for processing records and requires de-aggregation in your stream consumer. To learn more, see KPL Key Concepts and Consumer De-aggregation in the Amazon Kinesis Data Streams Developer Guide.
sourcepub fn set_aggregation_enabled(self, input: Option<bool>) -> Self
pub fn set_aggregation_enabled(self, input: Option<bool>) -> Self
Enables QLDB to publish multiple data records in a single Kinesis Data Streams record, increasing the number of records sent per API call.
Default: True
Record aggregation has important implications for processing records and requires de-aggregation in your stream consumer. To learn more, see KPL Key Concepts and Consumer De-aggregation in the Amazon Kinesis Data Streams Developer Guide.
sourcepub fn get_aggregation_enabled(&self) -> &Option<bool>
pub fn get_aggregation_enabled(&self) -> &Option<bool>
Enables QLDB to publish multiple data records in a single Kinesis Data Streams record, increasing the number of records sent per API call.
Default: True
Record aggregation has important implications for processing records and requires de-aggregation in your stream consumer. To learn more, see KPL Key Concepts and Consumer De-aggregation in the Amazon Kinesis Data Streams Developer Guide.
sourcepub fn build(self) -> Result<KinesisConfiguration, BuildError>
pub fn build(self) -> Result<KinesisConfiguration, BuildError>
Consumes the builder and constructs a KinesisConfiguration.
This method will fail if any of the following fields are not set:
Trait Implementations§
source§impl Clone for KinesisConfigurationBuilder
impl Clone for KinesisConfigurationBuilder
source§fn clone(&self) -> KinesisConfigurationBuilder
fn clone(&self) -> KinesisConfigurationBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for KinesisConfigurationBuilder
impl Debug for KinesisConfigurationBuilder
source§impl Default for KinesisConfigurationBuilder
impl Default for KinesisConfigurationBuilder
source§fn default() -> KinesisConfigurationBuilder
fn default() -> KinesisConfigurationBuilder
source§impl PartialEq for KinesisConfigurationBuilder
impl PartialEq for KinesisConfigurationBuilder
source§fn eq(&self, other: &KinesisConfigurationBuilder) -> bool
fn eq(&self, other: &KinesisConfigurationBuilder) -> bool
self and other values to be equal, and is used
by ==.impl StructuralPartialEq for KinesisConfigurationBuilder
Auto Trait Implementations§
impl Freeze for KinesisConfigurationBuilder
impl RefUnwindSafe for KinesisConfigurationBuilder
impl Send for KinesisConfigurationBuilder
impl Sync for KinesisConfigurationBuilder
impl Unpin for KinesisConfigurationBuilder
impl UnwindSafe for KinesisConfigurationBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit)source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more