Struct rusoto_iotanalytics::IotAnalyticsClient

pub struct IotAnalyticsClient { /* fields omitted */ }

A client for the AWS IoT Analytics API.

Methods

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,
    P::Future: Send,
    D: DispatchSignedRequest + Send + Sync + 'static,
    D::Future: Send, 

Trait Implementations

impl IotAnalytics for IotAnalyticsClient

fn batch_put_message(
    &self,
    input: BatchPutMessageRequest
) -> RusotoFuture<BatchPutMessageResponse, BatchPutMessageError>

Sends messages to a channel.

fn cancel_pipeline_reprocessing(
    &self,
    input: CancelPipelineReprocessingRequest
) -> RusotoFuture<CancelPipelineReprocessingResponse, CancelPipelineReprocessingError>

Cancels the reprocessing of data through the pipeline.

fn create_channel(
    &self,
    input: CreateChannelRequest
) -> RusotoFuture<CreateChannelResponse, CreateChannelError>

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(
    &self,
    input: CreateDatasetRequest
) -> RusotoFuture<CreateDatasetResponse, CreateDatasetError>

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.

fn create_dataset_content(
    &self,
    input: CreateDatasetContentRequest
) -> RusotoFuture<CreateDatasetContentResponse, CreateDatasetContentError>

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

fn create_datastore(
    &self,
    input: CreateDatastoreRequest
) -> RusotoFuture<CreateDatastoreResponse, CreateDatastoreError>

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

fn create_pipeline(
    &self,
    input: CreatePipelineRequest
) -> RusotoFuture<CreatePipelineResponse, CreatePipelineError>

Creates a pipeline. A pipeline consumes messages from one or more channels and allows you to process the messages before storing them in a data store.

fn delete_channel(
    &self,
    input: DeleteChannelRequest
) -> RusotoFuture<(), DeleteChannelError>

Deletes the specified channel.

fn delete_dataset(
    &self,
    input: DeleteDatasetRequest
) -> RusotoFuture<(), DeleteDatasetError>

Deletes the specified data set.

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

fn delete_dataset_content(
    &self,
    input: DeleteDatasetContentRequest
) -> RusotoFuture<(), DeleteDatasetContentError>

Deletes the content of the specified data set.

fn delete_datastore(
    &self,
    input: DeleteDatastoreRequest
) -> RusotoFuture<(), DeleteDatastoreError>

Deletes the specified data store.

fn delete_pipeline(
    &self,
    input: DeletePipelineRequest
) -> RusotoFuture<(), DeletePipelineError>

Deletes the specified pipeline.

fn describe_channel(
    &self,
    input: DescribeChannelRequest
) -> RusotoFuture<DescribeChannelResponse, DescribeChannelError>

Retrieves information about a channel.

fn describe_dataset(
    &self,
    input: DescribeDatasetRequest
) -> RusotoFuture<DescribeDatasetResponse, DescribeDatasetError>

Retrieves information about a data set.

fn describe_datastore(
    &self,
    input: DescribeDatastoreRequest
) -> RusotoFuture<DescribeDatastoreResponse, DescribeDatastoreError>

Retrieves information about a data store.

fn describe_logging_options(
    &self
) -> RusotoFuture<DescribeLoggingOptionsResponse, DescribeLoggingOptionsError>

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

fn describe_pipeline(
    &self,
    input: DescribePipelineRequest
) -> RusotoFuture<DescribePipelineResponse, DescribePipelineError>

Retrieves information about a pipeline.

fn get_dataset_content(
    &self,
    input: GetDatasetContentRequest
) -> RusotoFuture<GetDatasetContentResponse, GetDatasetContentError>

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

fn list_channels(
    &self,
    input: ListChannelsRequest
) -> RusotoFuture<ListChannelsResponse, ListChannelsError>

Retrieves a list of channels.

fn list_dataset_contents(
    &self,
    input: ListDatasetContentsRequest
) -> RusotoFuture<ListDatasetContentsResponse, ListDatasetContentsError>

Lists information about data set contents that have been created.

fn list_datasets(
    &self,
    input: ListDatasetsRequest
) -> RusotoFuture<ListDatasetsResponse, ListDatasetsError>

Retrieves information about data sets.

fn list_datastores(
    &self,
    input: ListDatastoresRequest
) -> RusotoFuture<ListDatastoresResponse, ListDatastoresError>

Retrieves a list of data stores.

fn list_pipelines(
    &self,
    input: ListPipelinesRequest
) -> RusotoFuture<ListPipelinesResponse, ListPipelinesError>

Retrieves a list of pipelines.

fn list_tags_for_resource(
    &self,
    input: ListTagsForResourceRequest
) -> RusotoFuture<ListTagsForResourceResponse, ListTagsForResourceError>

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

fn put_logging_options(
    &self,
    input: PutLoggingOptionsRequest
) -> RusotoFuture<(), PutLoggingOptionsError>

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.

fn run_pipeline_activity(
    &self,
    input: RunPipelineActivityRequest
) -> RusotoFuture<RunPipelineActivityResponse, RunPipelineActivityError>

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

fn sample_channel_data(
    &self,
    input: SampleChannelDataRequest
) -> RusotoFuture<SampleChannelDataResponse, SampleChannelDataError>

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(
    &self,
    input: StartPipelineReprocessingRequest
) -> RusotoFuture<StartPipelineReprocessingResponse, StartPipelineReprocessingError>

Starts the reprocessing of raw message data through the pipeline.

fn tag_resource(
    &self,
    input: TagResourceRequest
) -> RusotoFuture<TagResourceResponse, TagResourceError>

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

fn untag_resource(
    &self,
    input: UntagResourceRequest
) -> RusotoFuture<UntagResourceResponse, UntagResourceError>

Removes the given tags (metadata) from the resource.

fn update_channel(
    &self,
    input: UpdateChannelRequest
) -> RusotoFuture<(), UpdateChannelError>

Updates the settings of a channel.

fn update_dataset(
    &self,
    input: UpdateDatasetRequest
) -> RusotoFuture<(), UpdateDatasetError>

Updates the settings of a data set.

fn update_datastore(
    &self,
    input: UpdateDatastoreRequest
) -> RusotoFuture<(), UpdateDatastoreError>

Updates the settings of a data store.

fn update_pipeline(
    &self,
    input: UpdatePipelineRequest
) -> RusotoFuture<(), UpdatePipelineError>

Updates the settings of a pipeline.

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.