Struct PipelineActivity

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

An activity that performs a transformation on a message.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

channel: Option<ChannelActivity>

Determines the source of the messages to be processed.

lambda: Option<LambdaActivity>

Runs a Lambda function to modify the message.

datastore: Option<DatastoreActivity>

Specifies where to store the processed message data.

add_attributes: Option<AddAttributesActivity>

Adds other attributes based on existing attributes in the message.

remove_attributes: Option<RemoveAttributesActivity>

Removes attributes from a message.

select_attributes: Option<SelectAttributesActivity>

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

filter: Option<FilterActivity>

Filters a message based on its attributes.

math: Option<MathActivity>

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

device_registry_enrich: Option<DeviceRegistryEnrichActivity>

Adds data from the IoT device registry to your message.

device_shadow_enrich: Option<DeviceShadowEnrichActivity>

Adds information from the IoT Device Shadow service to 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 duplicate of the value.

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

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

Tests for self and other values to be equal, and is used by ==.

const fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PipelineActivity