Struct aws_sdk_kinesis::types::builders::ConsumerBuilder
source · #[non_exhaustive]pub struct ConsumerBuilder { /* private fields */ }
Expand description
A builder for Consumer
.
Implementations§
source§impl ConsumerBuilder
impl ConsumerBuilder
sourcepub fn consumer_name(self, input: impl Into<String>) -> Self
pub fn consumer_name(self, input: impl Into<String>) -> Self
The name of the consumer is something you choose when you register the consumer.
This field is required.sourcepub fn set_consumer_name(self, input: Option<String>) -> Self
pub fn set_consumer_name(self, input: Option<String>) -> Self
The name of the consumer is something you choose when you register the consumer.
sourcepub fn get_consumer_name(&self) -> &Option<String>
pub fn get_consumer_name(&self) -> &Option<String>
The name of the consumer is something you choose when you register the consumer.
sourcepub fn consumer_arn(self, input: impl Into<String>) -> Self
pub fn consumer_arn(self, input: impl Into<String>) -> Self
When you register a consumer, Kinesis Data Streams generates an ARN for it. You need this ARN to be able to call SubscribeToShard
.
If you delete a consumer and then create a new one with the same name, it won't have the same ARN. That's because consumer ARNs contain the creation timestamp. This is important to keep in mind if you have IAM policies that reference consumer ARNs.
This field is required.sourcepub fn set_consumer_arn(self, input: Option<String>) -> Self
pub fn set_consumer_arn(self, input: Option<String>) -> Self
When you register a consumer, Kinesis Data Streams generates an ARN for it. You need this ARN to be able to call SubscribeToShard
.
If you delete a consumer and then create a new one with the same name, it won't have the same ARN. That's because consumer ARNs contain the creation timestamp. This is important to keep in mind if you have IAM policies that reference consumer ARNs.
sourcepub fn get_consumer_arn(&self) -> &Option<String>
pub fn get_consumer_arn(&self) -> &Option<String>
When you register a consumer, Kinesis Data Streams generates an ARN for it. You need this ARN to be able to call SubscribeToShard
.
If you delete a consumer and then create a new one with the same name, it won't have the same ARN. That's because consumer ARNs contain the creation timestamp. This is important to keep in mind if you have IAM policies that reference consumer ARNs.
sourcepub fn consumer_status(self, input: ConsumerStatus) -> Self
pub fn consumer_status(self, input: ConsumerStatus) -> Self
A consumer can't read data while in the CREATING
or DELETING
states.
sourcepub fn set_consumer_status(self, input: Option<ConsumerStatus>) -> Self
pub fn set_consumer_status(self, input: Option<ConsumerStatus>) -> Self
A consumer can't read data while in the CREATING
or DELETING
states.
sourcepub fn get_consumer_status(&self) -> &Option<ConsumerStatus>
pub fn get_consumer_status(&self) -> &Option<ConsumerStatus>
A consumer can't read data while in the CREATING
or DELETING
states.
sourcepub fn consumer_creation_timestamp(self, input: DateTime) -> Self
pub fn consumer_creation_timestamp(self, input: DateTime) -> Self
sourcepub fn set_consumer_creation_timestamp(self, input: Option<DateTime>) -> Self
pub fn set_consumer_creation_timestamp(self, input: Option<DateTime>) -> Self
sourcepub fn get_consumer_creation_timestamp(&self) -> &Option<DateTime>
pub fn get_consumer_creation_timestamp(&self) -> &Option<DateTime>
Trait Implementations§
source§impl Clone for ConsumerBuilder
impl Clone for ConsumerBuilder
source§fn clone(&self) -> ConsumerBuilder
fn clone(&self) -> ConsumerBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for ConsumerBuilder
impl Debug for ConsumerBuilder
source§impl Default for ConsumerBuilder
impl Default for ConsumerBuilder
source§fn default() -> ConsumerBuilder
fn default() -> ConsumerBuilder
source§impl PartialEq for ConsumerBuilder
impl PartialEq for ConsumerBuilder
source§fn eq(&self, other: &ConsumerBuilder) -> bool
fn eq(&self, other: &ConsumerBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for ConsumerBuilder
Auto Trait Implementations§
impl Freeze for ConsumerBuilder
impl RefUnwindSafe for ConsumerBuilder
impl Send for ConsumerBuilder
impl Sync for ConsumerBuilder
impl Unpin for ConsumerBuilder
impl UnwindSafe for ConsumerBuilder
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> 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