Struct aws_sdk_iotanalytics::types::builders::PipelineActivityBuilder

#[non_exhaustive]
pub struct PipelineActivityBuilder { /* private fields */ }

A builder for PipelineActivity.

Implementations

impl PipelineActivityBuilder

pub fn channel(self, input: ChannelActivity) -> Self

Determines the source of the messages to be processed.

pub fn set_channel(self, input: Option<ChannelActivity>) -> Self

Determines the source of the messages to be processed.

pub fn get_channel(&self) -> &Option<ChannelActivity>

Determines the source of the messages to be processed.

pub fn lambda(self, input: LambdaActivity) -> Self

Runs a Lambda function to modify the message.

pub fn set_lambda(self, input: Option<LambdaActivity>) -> Self

Runs a Lambda function to modify the message.

pub fn get_lambda(&self) -> &Option<LambdaActivity>

Runs a Lambda function to modify the message.

pub fn datastore(self, input: DatastoreActivity) -> Self

Specifies where to store the processed message data.

pub fn set_datastore(self, input: Option<DatastoreActivity>) -> Self

Specifies where to store the processed message data.

pub fn get_datastore(&self) -> &Option<DatastoreActivity>

Specifies where to store the processed message data.

pub fn add_attributes(self, input: AddAttributesActivity) -> Self

Adds other attributes based on existing attributes in the message.

pub fn set_add_attributes(self, input: Option<AddAttributesActivity>) -> Self

Adds other attributes based on existing attributes in the message.

pub fn get_add_attributes(&self) -> &Option<AddAttributesActivity>

Adds other attributes based on existing attributes in the message.

pub fn remove_attributes(self, input: RemoveAttributesActivity) -> Self

Removes attributes from a message.

pub fn set_remove_attributes( self, input: Option<RemoveAttributesActivity> ) -> Self

Removes attributes from a message.

pub fn get_remove_attributes(&self) -> &Option<RemoveAttributesActivity>

Removes attributes from a message.

pub fn select_attributes(self, input: SelectAttributesActivity) -> Self

Used to create a new message using only the specified attributes from the original message.

pub fn set_select_attributes( self, input: Option<SelectAttributesActivity> ) -> Self

Used to create a new message using only the specified attributes from the original message.

pub fn get_select_attributes(&self) -> &Option<SelectAttributesActivity>

Used to create a new message using only the specified attributes from the original message.

pub fn filter(self, input: FilterActivity) -> Self

Filters a message based on its attributes.

pub fn set_filter(self, input: Option<FilterActivity>) -> Self

Filters a message based on its attributes.

pub fn get_filter(&self) -> &Option<FilterActivity>

Filters a message based on its attributes.

pub fn math(self, input: MathActivity) -> Self

Computes an arithmetic expression using the message's attributes and adds it to the message.

pub fn set_math(self, input: Option<MathActivity>) -> Self

Computes an arithmetic expression using the message's attributes and adds it to the message.

pub fn get_math(&self) -> &Option<MathActivity>

Computes an arithmetic expression using the message's attributes and adds it to the message.

pub fn device_registry_enrich(self, input: DeviceRegistryEnrichActivity) -> Self

Adds data from the IoT device registry to your message.

pub fn set_device_registry_enrich( self, input: Option<DeviceRegistryEnrichActivity> ) -> Self

Adds data from the IoT device registry to your message.

pub fn get_device_registry_enrich( &self ) -> &Option<DeviceRegistryEnrichActivity>

Adds data from the IoT device registry to your message.

pub fn device_shadow_enrich(self, input: DeviceShadowEnrichActivity) -> Self

Adds information from the IoT Device Shadow service to a message.

pub fn set_device_shadow_enrich( self, input: Option<DeviceShadowEnrichActivity> ) -> Self

Adds information from the IoT Device Shadow service to a message.

pub fn get_device_shadow_enrich(&self) -> &Option<DeviceShadowEnrichActivity>

Adds information from the IoT Device Shadow service to a message.

pub fn build(self) -> PipelineActivity

Consumes the builder and constructs a PipelineActivity.

Trait Implementations

impl Clone for PipelineActivityBuilder

fn clone(&self) -> PipelineActivityBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineActivityBuilder

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

Formats the value using the given formatter.

impl Default for PipelineActivityBuilder

fn default() -> PipelineActivityBuilder

Returns the “default value” for a type.

impl PartialEq for PipelineActivityBuilder

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

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

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.

impl StructuralPartialEq for PipelineActivityBuilder