#[non_exhaustive]pub struct Builder { /* private fields */ }
Expand description
A builder for Action
Implementations
sourceimpl Builder
impl Builder
sourcepub fn dynamo_db(self, input: DynamoDbAction) -> Self
pub fn dynamo_db(self, input: DynamoDbAction) -> Self
Write to a DynamoDB table.
sourcepub fn set_dynamo_db(self, input: Option<DynamoDbAction>) -> Self
pub fn set_dynamo_db(self, input: Option<DynamoDbAction>) -> Self
Write to a DynamoDB table.
sourcepub fn dynamo_d_bv2(self, input: DynamoDBv2Action) -> Self
pub fn dynamo_d_bv2(self, input: DynamoDBv2Action) -> Self
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.
sourcepub fn set_dynamo_d_bv2(self, input: Option<DynamoDBv2Action>) -> Self
pub fn set_dynamo_d_bv2(self, input: Option<DynamoDBv2Action>) -> Self
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.
sourcepub fn lambda(self, input: LambdaAction) -> Self
pub fn lambda(self, input: LambdaAction) -> Self
Invoke a Lambda function.
sourcepub fn set_lambda(self, input: Option<LambdaAction>) -> Self
pub fn set_lambda(self, input: Option<LambdaAction>) -> Self
Invoke a Lambda function.
sourcepub fn kinesis(self, input: KinesisAction) -> Self
pub fn kinesis(self, input: KinesisAction) -> Self
Write data to an Amazon Kinesis stream.
sourcepub fn set_kinesis(self, input: Option<KinesisAction>) -> Self
pub fn set_kinesis(self, input: Option<KinesisAction>) -> Self
Write data to an Amazon Kinesis stream.
sourcepub fn republish(self, input: RepublishAction) -> Self
pub fn republish(self, input: RepublishAction) -> Self
Publish to another MQTT topic.
sourcepub fn set_republish(self, input: Option<RepublishAction>) -> Self
pub fn set_republish(self, input: Option<RepublishAction>) -> Self
Publish to another MQTT topic.
sourcepub fn firehose(self, input: FirehoseAction) -> Self
pub fn firehose(self, input: FirehoseAction) -> Self
Write to an Amazon Kinesis Firehose stream.
sourcepub fn set_firehose(self, input: Option<FirehoseAction>) -> Self
pub fn set_firehose(self, input: Option<FirehoseAction>) -> Self
Write to an Amazon Kinesis Firehose stream.
sourcepub fn cloudwatch_metric(self, input: CloudwatchMetricAction) -> Self
pub fn cloudwatch_metric(self, input: CloudwatchMetricAction) -> Self
Capture a CloudWatch metric.
sourcepub fn set_cloudwatch_metric(
self,
input: Option<CloudwatchMetricAction>
) -> Self
pub fn set_cloudwatch_metric(
self,
input: Option<CloudwatchMetricAction>
) -> Self
Capture a CloudWatch metric.
sourcepub fn cloudwatch_alarm(self, input: CloudwatchAlarmAction) -> Self
pub fn cloudwatch_alarm(self, input: CloudwatchAlarmAction) -> Self
Change the state of a CloudWatch alarm.
sourcepub fn set_cloudwatch_alarm(self, input: Option<CloudwatchAlarmAction>) -> Self
pub fn set_cloudwatch_alarm(self, input: Option<CloudwatchAlarmAction>) -> Self
Change the state of a CloudWatch alarm.
sourcepub fn cloudwatch_logs(self, input: CloudwatchLogsAction) -> Self
pub fn cloudwatch_logs(self, input: CloudwatchLogsAction) -> Self
Send data to CloudWatch Logs.
sourcepub fn set_cloudwatch_logs(self, input: Option<CloudwatchLogsAction>) -> Self
pub fn set_cloudwatch_logs(self, input: Option<CloudwatchLogsAction>) -> Self
Send data to CloudWatch Logs.
sourcepub fn elasticsearch(self, input: ElasticsearchAction) -> Self
pub fn elasticsearch(self, input: ElasticsearchAction) -> Self
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.
sourcepub fn set_elasticsearch(self, input: Option<ElasticsearchAction>) -> Self
pub fn set_elasticsearch(self, input: Option<ElasticsearchAction>) -> Self
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.
sourcepub fn salesforce(self, input: SalesforceAction) -> Self
pub fn salesforce(self, input: SalesforceAction) -> Self
Send a message to a Salesforce IoT Cloud Input Stream.
sourcepub fn set_salesforce(self, input: Option<SalesforceAction>) -> Self
pub fn set_salesforce(self, input: Option<SalesforceAction>) -> Self
Send a message to a Salesforce IoT Cloud Input Stream.
sourcepub fn iot_analytics(self, input: IotAnalyticsAction) -> Self
pub fn iot_analytics(self, input: IotAnalyticsAction) -> Self
Sends message data to an IoT Analytics channel.
sourcepub fn set_iot_analytics(self, input: Option<IotAnalyticsAction>) -> Self
pub fn set_iot_analytics(self, input: Option<IotAnalyticsAction>) -> Self
Sends message data to an IoT Analytics channel.
sourcepub fn iot_events(self, input: IotEventsAction) -> Self
pub fn iot_events(self, input: IotEventsAction) -> Self
Sends an input to an IoT Events detector.
sourcepub fn set_iot_events(self, input: Option<IotEventsAction>) -> Self
pub fn set_iot_events(self, input: Option<IotEventsAction>) -> Self
Sends an input to an IoT Events detector.
sourcepub fn iot_site_wise(self, input: IotSiteWiseAction) -> Self
pub fn iot_site_wise(self, input: IotSiteWiseAction) -> Self
Sends data from the MQTT message that triggered the rule to IoT SiteWise asset properties.
sourcepub fn set_iot_site_wise(self, input: Option<IotSiteWiseAction>) -> Self
pub fn set_iot_site_wise(self, input: Option<IotSiteWiseAction>) -> Self
Sends data from the MQTT message that triggered the rule to IoT SiteWise asset properties.
sourcepub fn step_functions(self, input: StepFunctionsAction) -> Self
pub fn step_functions(self, input: StepFunctionsAction) -> Self
Starts execution of a Step Functions state machine.
sourcepub fn set_step_functions(self, input: Option<StepFunctionsAction>) -> Self
pub fn set_step_functions(self, input: Option<StepFunctionsAction>) -> Self
Starts execution of a Step Functions state machine.
sourcepub fn timestream(self, input: TimestreamAction) -> Self
pub fn timestream(self, input: TimestreamAction) -> Self
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.
sourcepub fn set_timestream(self, input: Option<TimestreamAction>) -> Self
pub fn set_timestream(self, input: Option<TimestreamAction>) -> Self
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.
sourcepub fn http(self, input: HttpAction) -> Self
pub fn http(self, input: HttpAction) -> Self
Send data to an HTTPS endpoint.
sourcepub fn set_http(self, input: Option<HttpAction>) -> Self
pub fn set_http(self, input: Option<HttpAction>) -> Self
Send data to an HTTPS endpoint.
sourcepub fn kafka(self, input: KafkaAction) -> Self
pub fn kafka(self, input: KafkaAction) -> Self
Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.
sourcepub fn set_kafka(self, input: Option<KafkaAction>) -> Self
pub fn set_kafka(self, input: Option<KafkaAction>) -> Self
Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.
sourcepub fn open_search(self, input: OpenSearchAction) -> Self
pub fn open_search(self, input: OpenSearchAction) -> Self
Write data to an Amazon OpenSearch Service domain.
sourcepub fn set_open_search(self, input: Option<OpenSearchAction>) -> Self
pub fn set_open_search(self, input: Option<OpenSearchAction>) -> Self
Write data to an Amazon OpenSearch Service domain.
Trait Implementations
impl StructuralPartialEq for Builder
Auto Trait Implementations
impl RefUnwindSafe for Builder
impl Send for Builder
impl Sync for Builder
impl Unpin for Builder
impl UnwindSafe for Builder
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more