Struct rusoto_iotanalytics::IotAnalyticsClient

pub struct IotAnalyticsClient { /* fields omitted */ }

A client for the AWS IoT Analytics API.

Implementations

impl IotAnalyticsClient

pub fn new(region: Region) -> IotAnalyticsClient

Creates a client backed by the default tokio event loop.

The client will use the default credentials provider and tls client.

pub fn new_with<P, D>(
    request_dispatcher: D,
    credentials_provider: P,
    region: Region
) -> IotAnalyticsClient where
    P: ProvideAwsCredentials + Send + Sync + 'static,
    D: DispatchSignedRequest + Send + Sync + 'static, 

pub fn new_with_client(client: Client, region: Region) -> IotAnalyticsClient

Trait Implementations

impl Clone for IotAnalyticsClient

pub fn clone(&self) -> IotAnalyticsClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl IotAnalytics for IotAnalyticsClient

pub fn batch_put_message<'life0, 'async_trait>(
    &'life0 self,
    input: BatchPutMessageRequest
) -> Pin<Box<dyn Future<Output = Result<BatchPutMessageResponse, RusotoError<BatchPutMessageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Sends messages to a channel.

pub fn cancel_pipeline_reprocessing<'life0, 'async_trait>(
    &'life0 self,
    input: CancelPipelineReprocessingRequest
) -> Pin<Box<dyn Future<Output = Result<CancelPipelineReprocessingResponse, RusotoError<CancelPipelineReprocessingError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Cancels the reprocessing of data through the pipeline.

pub fn create_channel<'life0, 'async_trait>(
    &'life0 self,
    input: CreateChannelRequest
) -> Pin<Box<dyn Future<Output = Result<CreateChannelResponse, RusotoError<CreateChannelError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.

pub fn create_dataset<'life0, 'async_trait>(
    &'life0 self,
    input: CreateDatasetRequest
) -> Pin<Box<dyn Future<Output = Result<CreateDatasetResponse, RusotoError<CreateDatasetError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a data set. A data set stores data retrieved from a data store by applying a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application). This operation creates the skeleton of a data set. The data set can be populated manually by calling "CreateDatasetContent" or automatically according to a "trigger" you specify.

pub fn create_dataset_content<'life0, 'async_trait>(
    &'life0 self,
    input: CreateDatasetContentRequest
) -> Pin<Box<dyn Future<Output = Result<CreateDatasetContentResponse, RusotoError<CreateDatasetContentError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates the content of a data set by applying a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application).

pub fn create_datastore<'life0, 'async_trait>(
    &'life0 self,
    input: CreateDatastoreRequest
) -> Pin<Box<dyn Future<Output = Result<CreateDatastoreResponse, RusotoError<CreateDatastoreError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a data store, which is a repository for messages.

pub fn create_pipeline<'life0, 'async_trait>(
    &'life0 self,
    input: CreatePipelineRequest
) -> Pin<Box<dyn Future<Output = Result<CreatePipelineResponse, RusotoError<CreatePipelineError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a pipeline. A pipeline consumes messages from a channel and allows you to process the messages before storing them in a data store. You must specify both a channel and a datastore activity and, optionally, as many as 23 additional activities in the pipelineActivities array.

pub fn delete_channel<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteChannelRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<DeleteChannelError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Deletes the specified channel.

pub fn delete_dataset<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteDatasetRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<DeleteDatasetError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Deletes the specified data set.

You do not have to delete the content of the data set before you perform this operation.

pub fn delete_dataset_content<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteDatasetContentRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<DeleteDatasetContentError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Deletes the content of the specified data set.

pub fn delete_datastore<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteDatastoreRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<DeleteDatastoreError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Deletes the specified data store.

pub fn delete_pipeline<'life0, 'async_trait>(
    &'life0 self,
    input: DeletePipelineRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<DeletePipelineError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Deletes the specified pipeline.

pub fn describe_channel<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeChannelRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeChannelResponse, RusotoError<DescribeChannelError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves information about a channel.

pub fn describe_dataset<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeDatasetRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeDatasetResponse, RusotoError<DescribeDatasetError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves information about a data set.

pub fn describe_datastore<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeDatastoreRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeDatastoreResponse, RusotoError<DescribeDatastoreError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves information about a data store.

pub fn describe_logging_options<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<DescribeLoggingOptionsResponse, RusotoError<DescribeLoggingOptionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves the current settings of the AWS IoT Analytics logging options.

pub fn describe_pipeline<'life0, 'async_trait>(
    &'life0 self,
    input: DescribePipelineRequest
) -> Pin<Box<dyn Future<Output = Result<DescribePipelineResponse, RusotoError<DescribePipelineError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves information about a pipeline.

pub fn get_dataset_content<'life0, 'async_trait>(
    &'life0 self,
    input: GetDatasetContentRequest
) -> Pin<Box<dyn Future<Output = Result<GetDatasetContentResponse, RusotoError<GetDatasetContentError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves the contents of a data set as pre-signed URIs.

pub fn list_channels<'life0, 'async_trait>(
    &'life0 self,
    input: ListChannelsRequest
) -> Pin<Box<dyn Future<Output = Result<ListChannelsResponse, RusotoError<ListChannelsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves a list of channels.

pub fn list_dataset_contents<'life0, 'async_trait>(
    &'life0 self,
    input: ListDatasetContentsRequest
) -> Pin<Box<dyn Future<Output = Result<ListDatasetContentsResponse, RusotoError<ListDatasetContentsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists information about data set contents that have been created.

pub fn list_datasets<'life0, 'async_trait>(
    &'life0 self,
    input: ListDatasetsRequest
) -> Pin<Box<dyn Future<Output = Result<ListDatasetsResponse, RusotoError<ListDatasetsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves information about data sets.

pub fn list_datastores<'life0, 'async_trait>(
    &'life0 self,
    input: ListDatastoresRequest
) -> Pin<Box<dyn Future<Output = Result<ListDatastoresResponse, RusotoError<ListDatastoresError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves a list of data stores.

pub fn list_pipelines<'life0, 'async_trait>(
    &'life0 self,
    input: ListPipelinesRequest
) -> Pin<Box<dyn Future<Output = Result<ListPipelinesResponse, RusotoError<ListPipelinesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves a list of pipelines.

pub fn list_tags_for_resource<'life0, 'async_trait>(
    &'life0 self,
    input: ListTagsForResourceRequest
) -> Pin<Box<dyn Future<Output = Result<ListTagsForResourceResponse, RusotoError<ListTagsForResourceError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists the tags (metadata) which you have assigned to the resource.

pub fn put_logging_options<'life0, 'async_trait>(
    &'life0 self,
    input: PutLoggingOptionsRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<PutLoggingOptionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Sets or updates the AWS IoT Analytics logging options.

Note that if you update the value of any loggingOptions field, it takes up to one minute for the change to take effect. Also, if you change the policy attached to the role you specified in the roleArn field (for example, to correct an invalid policy) it takes up to 5 minutes for that change to take effect.

pub fn run_pipeline_activity<'life0, 'async_trait>(
    &'life0 self,
    input: RunPipelineActivityRequest
) -> Pin<Box<dyn Future<Output = Result<RunPipelineActivityResponse, RusotoError<RunPipelineActivityError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Simulates the results of running a pipeline activity on a message payload.

pub fn sample_channel_data<'life0, 'async_trait>(
    &'life0 self,
    input: SampleChannelDataRequest
) -> Pin<Box<dyn Future<Output = Result<SampleChannelDataResponse, RusotoError<SampleChannelDataError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.

pub fn start_pipeline_reprocessing<'life0, 'async_trait>(
    &'life0 self,
    input: StartPipelineReprocessingRequest
) -> Pin<Box<dyn Future<Output = Result<StartPipelineReprocessingResponse, RusotoError<StartPipelineReprocessingError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Starts the reprocessing of raw message data through the pipeline.

pub fn tag_resource<'life0, 'async_trait>(
    &'life0 self,
    input: TagResourceRequest
) -> Pin<Box<dyn Future<Output = Result<TagResourceResponse, RusotoError<TagResourceError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Adds to or modifies the tags of the given resource. Tags are metadata which can be used to manage a resource.

pub fn untag_resource<'life0, 'async_trait>(
    &'life0 self,
    input: UntagResourceRequest
) -> Pin<Box<dyn Future<Output = Result<UntagResourceResponse, RusotoError<UntagResourceError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Removes the given tags (metadata) from the resource.

pub fn update_channel<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateChannelRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<UpdateChannelError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Updates the settings of a channel.

pub fn update_dataset<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateDatasetRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<UpdateDatasetError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Updates the settings of a data set.

pub fn update_datastore<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateDatastoreRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<UpdateDatastoreError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Updates the settings of a data store.

pub fn update_pipeline<'life0, 'async_trait>(
    &'life0 self,
    input: UpdatePipelineRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<UpdatePipelineError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Updates the settings of a pipeline. You must specify both a channel and a datastore activity and, optionally, as many as 23 additional activities in the pipelineActivities array.