Struct aws_sdk_iotanalytics::types::PipelineActivity

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

An activity that performs a transformation on a message.

Implementations

impl PipelineActivity

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

Determines the source of the messages to be processed.

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

Runs a Lambda function to modify the message.

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

Specifies where to store the processed message data.

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

Adds other attributes based on existing attributes in the message.

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

Removes attributes from a message.

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

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

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

Filters a message based on its attributes.

pub fn 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) -> Option<&DeviceRegistryEnrichActivity>

Adds data from the IoT device registry to your message.

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

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

impl PipelineActivity

pub fn builder() -> PipelineActivityBuilder

Creates a new builder-style object to manufacture PipelineActivity.

Trait Implementations

impl Clone for PipelineActivity

fn clone(&self) -> PipelineActivity

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineActivity

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

Formats the value using the given formatter.

impl PartialEq<PipelineActivity> for PipelineActivity

fn eq(&self, other: &PipelineActivity) -> 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 PipelineActivity