Struct rusoto_iotanalytics::PipelineActivity

pub struct PipelineActivity {
    pub add_attributes: Option<AddAttributesActivity>,
    pub channel: Option<ChannelActivity>,
    pub datastore: Option<DatastoreActivity>,
    pub device_registry_enrich: Option<DeviceRegistryEnrichActivity>,
    pub device_shadow_enrich: Option<DeviceShadowEnrichActivity>,
    pub filter: Option<FilterActivity>,
    pub lambda: Option<LambdaActivity>,
    pub math: Option<MathActivity>,
    pub remove_attributes: Option<RemoveAttributesActivity>,
    pub select_attributes: Option<SelectAttributesActivity>,
}

An activity that performs a transformation on a message.

Fields

add_attributes: Option<AddAttributesActivity>

Adds other attributes based on existing attributes in the message.

channel: Option<ChannelActivity>

Determines the source of the messages to be processed.

datastore: Option<DatastoreActivity>

Specifies where to store the processed message data.

device_registry_enrich: Option<DeviceRegistryEnrichActivity>

Adds data from the AWS IoT device registry to your message.

device_shadow_enrich: Option<DeviceShadowEnrichActivity>

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

filter: Option<FilterActivity>

Filters a message based on its attributes.

lambda: Option<LambdaActivity>

Runs a Lambda function to modify the message.

math: Option<MathActivity>

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

remove_attributes: Option<RemoveAttributesActivity>

Removes attributes from a message.

select_attributes: Option<SelectAttributesActivity>

Creates a new message using only the specified attributes from the original message.

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 Default for PipelineActivity

fn default() -> PipelineActivity

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PipelineActivity

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

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: &PipelineActivity) -> bool

This method tests for !=.

impl Serialize for PipelineActivity

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PipelineActivity