Struct aws_sdk_iot::types::Action

source ·
#[non_exhaustive]
pub struct Action {
Show 23 fields pub dynamo_db: Option<DynamoDbAction>, pub dynamo_dbv2: Option<DynamoDBv2Action>, pub lambda: Option<LambdaAction>, pub sns: Option<SnsAction>, pub sqs: Option<SqsAction>, pub kinesis: Option<KinesisAction>, pub republish: Option<RepublishAction>, pub s3: Option<S3Action>, pub firehose: Option<FirehoseAction>, pub cloudwatch_metric: Option<CloudwatchMetricAction>, pub cloudwatch_alarm: Option<CloudwatchAlarmAction>, pub cloudwatch_logs: Option<CloudwatchLogsAction>, pub elasticsearch: Option<ElasticsearchAction>, pub salesforce: Option<SalesforceAction>, pub iot_analytics: Option<IotAnalyticsAction>, pub iot_events: Option<IotEventsAction>, pub iot_site_wise: Option<IotSiteWiseAction>, pub step_functions: Option<StepFunctionsAction>, pub timestream: Option<TimestreamAction>, pub http: Option<HttpAction>, pub kafka: Option<KafkaAction>, pub open_search: Option<OpenSearchAction>, pub location: Option<LocationAction>,
}
Expand description

Describes the actions associated with a rule.

Fields (Non-exhaustive)§

This struct is marked as 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.
§dynamo_db: Option<DynamoDbAction>

Write to a DynamoDB table.

§dynamo_dbv2: Option<DynamoDBv2Action>

Write to a DynamoDB table. This is a new version of the DynamoDB action. It allows you to write each attribute in an MQTT message payload into a separate DynamoDB column.

§lambda: Option<LambdaAction>

Invoke a Lambda function.

§sns: Option<SnsAction>

Publish to an Amazon SNS topic.

§sqs: Option<SqsAction>

Publish to an Amazon SQS queue.

§kinesis: Option<KinesisAction>

Write data to an Amazon Kinesis stream.

§republish: Option<RepublishAction>

Publish to another MQTT topic.

§s3: Option<S3Action>

Write to an Amazon S3 bucket.

§firehose: Option<FirehoseAction>

Write to an Amazon Kinesis Firehose stream.

§cloudwatch_metric: Option<CloudwatchMetricAction>

Capture a CloudWatch metric.

§cloudwatch_alarm: Option<CloudwatchAlarmAction>

Change the state of a CloudWatch alarm.

§cloudwatch_logs: Option<CloudwatchLogsAction>

Send data to CloudWatch Logs.

§elasticsearch: Option<ElasticsearchAction>

Write data to an Amazon OpenSearch Service domain.

The Elasticsearch action can only be used by existing rule actions. To create a new rule action or to update an existing rule action, use the OpenSearch rule action instead. For more information, see OpenSearchAction.

§salesforce: Option<SalesforceAction>

Send a message to a Salesforce IoT Cloud Input Stream.

§iot_analytics: Option<IotAnalyticsAction>

Sends message data to an IoT Analytics channel.

§iot_events: Option<IotEventsAction>

Sends an input to an IoT Events detector.

§iot_site_wise: Option<IotSiteWiseAction>

Sends data from the MQTT message that triggered the rule to IoT SiteWise asset properties.

§step_functions: Option<StepFunctionsAction>

Starts execution of a Step Functions state machine.

§timestream: Option<TimestreamAction>

The Timestream rule action writes attributes (measures) from an MQTT message into an Amazon Timestream table. For more information, see the Timestream topic rule action documentation.

§http: Option<HttpAction>

Send data to an HTTPS endpoint.

§kafka: Option<KafkaAction>

Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.

§open_search: Option<OpenSearchAction>

Write data to an Amazon OpenSearch Service domain.

§location: Option<LocationAction>

The Amazon Location Service rule action sends device location updates from an MQTT message to an Amazon Location tracker resource.

Implementations§

source§

impl Action

source

pub fn dynamo_db(&self) -> Option<&DynamoDbAction>

Write to a DynamoDB table.

source

pub fn dynamo_dbv2(&self) -> Option<&DynamoDBv2Action>

Write to a DynamoDB table. This is a new version of the DynamoDB action. It allows you to write each attribute in an MQTT message payload into a separate DynamoDB column.

source

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

Invoke a Lambda function.

source

pub fn sns(&self) -> Option<&SnsAction>

Publish to an Amazon SNS topic.

source

pub fn sqs(&self) -> Option<&SqsAction>

Publish to an Amazon SQS queue.

source

pub fn kinesis(&self) -> Option<&KinesisAction>

Write data to an Amazon Kinesis stream.

source

pub fn republish(&self) -> Option<&RepublishAction>

Publish to another MQTT topic.

source

pub fn s3(&self) -> Option<&S3Action>

Write to an Amazon S3 bucket.

source

pub fn firehose(&self) -> Option<&FirehoseAction>

Write to an Amazon Kinesis Firehose stream.

source

pub fn cloudwatch_metric(&self) -> Option<&CloudwatchMetricAction>

Capture a CloudWatch metric.

source

pub fn cloudwatch_alarm(&self) -> Option<&CloudwatchAlarmAction>

Change the state of a CloudWatch alarm.

source

pub fn cloudwatch_logs(&self) -> Option<&CloudwatchLogsAction>

Send data to CloudWatch Logs.

source

pub fn elasticsearch(&self) -> Option<&ElasticsearchAction>

Write data to an Amazon OpenSearch Service domain.

The Elasticsearch action can only be used by existing rule actions. To create a new rule action or to update an existing rule action, use the OpenSearch rule action instead. For more information, see OpenSearchAction.

source

pub fn salesforce(&self) -> Option<&SalesforceAction>

Send a message to a Salesforce IoT Cloud Input Stream.

source

pub fn iot_analytics(&self) -> Option<&IotAnalyticsAction>

Sends message data to an IoT Analytics channel.

source

pub fn iot_events(&self) -> Option<&IotEventsAction>

Sends an input to an IoT Events detector.

source

pub fn iot_site_wise(&self) -> Option<&IotSiteWiseAction>

Sends data from the MQTT message that triggered the rule to IoT SiteWise asset properties.

source

pub fn step_functions(&self) -> Option<&StepFunctionsAction>

Starts execution of a Step Functions state machine.

source

pub fn timestream(&self) -> Option<&TimestreamAction>

The Timestream rule action writes attributes (measures) from an MQTT message into an Amazon Timestream table. For more information, see the Timestream topic rule action documentation.

source

pub fn http(&self) -> Option<&HttpAction>

Send data to an HTTPS endpoint.

source

pub fn kafka(&self) -> Option<&KafkaAction>

Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.

Write data to an Amazon OpenSearch Service domain.

source

pub fn location(&self) -> Option<&LocationAction>

The Amazon Location Service rule action sends device location updates from an MQTT message to an Amazon Location tracker resource.

source§

impl Action

source

pub fn builder() -> ActionBuilder

Creates a new builder-style object to manufacture Action.

Trait Implementations§

source§

impl Clone for Action

source§

fn clone(&self) -> Action

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for Action

source§

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

Formats the value using the given formatter. Read more
source§

impl PartialEq for Action

source§

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

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

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.
source§

impl StructuralPartialEq for Action

Auto Trait Implementations§

§

impl Freeze for Action

§

impl RefUnwindSafe for Action

§

impl Send for Action

§

impl Sync for Action

§

impl Unpin for Action

§

impl UnwindSafe for Action

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more