Struct rusoto_iotanalytics::IotAnalyticsClient

pub struct IotAnalyticsClient { /* private fields */ }

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

fn clone(&self) -> IotAnalyticsClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl IotAnalytics for IotAnalyticsClient

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.

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.

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.

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 dataset. A dataset 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 dataset. The dataset can be populated manually by calling CreateDatasetContent or automatically according to a trigger you specify.

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).

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. Only data stores that are used to save pipeline data can be configured with ParquetConfiguration.

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.

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.

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 dataset.

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

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 dataset.

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.

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.

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.

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 dataset.

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.

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.

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.

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 presigned URIs.

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.

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.

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.

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.

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.

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) that you have assigned to the resource.

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.

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 five minutes for that change to take effect.

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.

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.

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.

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 that can be used to manage a resource.

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.

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.

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.

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.

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.