Struct Client 

pub struct Client { /* private fields */ }

Client for AWS Elemental Inference

Client for invoking operations on AWS Elemental Inference. Each operation on AWS Elemental Inference is a method on this this struct. .send() MUST be invoked on the generated operations to dispatch the request to the service.

Constructing a Client

A Config is required to construct a client. For most use cases, the aws-config crate should be used to automatically resolve this config using aws_config::load_from_env(), since this will resolve an SdkConfig which can be shared across multiple different AWS SDK clients. This config resolution process can be customized by calling aws_config::from_env() instead, which returns a ConfigLoader that uses the builder pattern to customize the default config.

In the simplest case, creating a client looks as follows:

let config = aws_config::load_from_env().await;
let client = aws_sdk_elementalinference::Client::new(&config);

Occasionally, SDKs may have additional service-specific values that can be set on the Config that is absent from SdkConfig, or slightly different settings for a specific client may be desired. The Builder struct implements From<&SdkConfig>, so setting these specific settings can be done as follows:

let sdk_config = ::aws_config::load_from_env().await;
let config = aws_sdk_elementalinference::config::Builder::from(&sdk_config)
    .some_service_specific_setting("value")
    .build();

See the aws-config docs and Config for more information on customizing configuration.

Note: Client construction is expensive due to connection thread pool initialization, and should be done once at application start-up.

Using the Client

A client has a function for every operation that can be performed by the service. For example, the AssociateFeed operation has a Client::associate_feed, function which returns a builder for that operation. The fluent builder ultimately has a send() function that returns an async future that returns a result, as illustrated below:

let result = client.associate_feed()
    .id("example")
    .send()
    .await;

The underlying HTTP requests that get made by this can be modified with the customize_operation function on the fluent builder. See the customize module for more information.

Waiters

This client provides wait_until methods behind the Waiters trait. To use them, simply import the trait, and then call one of the wait_until methods. This will return a waiter fluent builder that takes various parameters, which are documented on the builder type. Once parameters have been provided, the wait method can be called to initiate waiting.

For example, if there was a wait_until_thing method, it could look like:

let result = client.wait_until_thing()
    .thing_id("someId")
    .wait(Duration::from_secs(120))
    .await;

Implementations

impl Client

pub fn associate_feed(&self) -> AssociateFeedFluentBuilder

Constructs a fluent builder for the AssociateFeed operation.

• The fluent builder is configurable:
  • id(impl Into<String>) / set_id(Option<String>):
    required: true
    

    The ID of the feed.

    
    
  • associated_resource_name(impl Into<String>) / set_associated_resource_name(Option<String>):
    required: true
    

    An identifier for the resource. If the resource is from an AWS service, this identifier must be the full ARN of that resource. Otherwise, the identifier is a name that you assign and that is appropriate for the application that owns the resource. This name must not resemble an ARN.

    
    
  • outputs(CreateOutput) / set_outputs(Option<Vec::<CreateOutput>>):
    required: true
    

    The outputs to add to this feed. You must specify at least one output. You can later use the UpdateFeed action to change the list of outputs.

    
    
  • dry_run(bool) / set_dry_run(Option<bool>):
    required: false
    

    Set to true if you want to do a dry run of the associate action.

    
    
• On success, responds with AssociateFeedOutput with field(s):
  • arn(String):

    The AWS ARN for this association.

  • id(String):

    An ID for this response. It is unique in Elemental Inference for this AWS account.

• On failure, responds with SdkError<AssociateFeedError>

impl Client

pub fn create_feed(&self) -> CreateFeedFluentBuilder

Constructs a fluent builder for the CreateFeed operation.

• The fluent builder is configurable:
  • name(impl Into<String>) / set_name(Option<String>):
    required: true
    

    A name for this feed.

    
    
  • outputs(CreateOutput) / set_outputs(Option<Vec::<CreateOutput>>):
    required: true
    

    An array of outputs for this feed. Each output represents a specific Elemental Inference feature. For example, an output might represent the crop feature.

    
    
  • tags(impl Into<String>, impl Into<String>) / set_tags(Option<HashMap::<String, String>>):
    required: false
    

    If you want to include tags, add them now. You won’t be able to add them later.

    
    
• On success, responds with CreateFeedOutput with field(s):
  • arn(String):

    A unique ARN that Elemental Inference assigns to the feed.

  • name(String):

    The name that you specified.

  • id(String):

    A unique ID that Elemental Inference assigns to the feed.

  • data_endpoints(Vec::<String>):

    A unique ARN that Elemental Inference assigns to the feed.

  • outputs(Vec::<GetOutput>):

    Data endpoints that Elemental Inference assigns to the feed.

  • status(FeedStatus):

    The current status of the feed. After creation of the feed has succeeded, the status will be AVAILABLE.

  • association(Option<FeedAssociation>):

    The association for this feed. When you create the feed, this property is empty. You must associate a resource with the feed using AssociateFeed.

  • tags(Option<HashMap::<String, String>>):

    Any tags that you included when you created the feed.

• On failure, responds with SdkError<CreateFeedError>

impl Client

pub fn delete_feed(&self) -> DeleteFeedFluentBuilder

Constructs a fluent builder for the DeleteFeed operation.

• The fluent builder is configurable:
  • id(impl Into<String>) / set_id(Option<String>):
    required: true
    

    The ID of the feed.

    
    
• On success, responds with DeleteFeedOutput with field(s):
  • arn(String):

    The ARN of the deleted feed.

  • id(String):

    The ID of the deleted feed.

  • status(FeedStatus):

    The current status of the feed. When deletion of the feed has succeeded, the status will be DELETED.

• On failure, responds with SdkError<DeleteFeedError>

impl Client

pub fn disassociate_feed(&self) -> DisassociateFeedFluentBuilder

Constructs a fluent builder for the DisassociateFeed operation.

• The fluent builder is configurable:
  • id(impl Into<String>) / set_id(Option<String>):
    required: true
    

    The ID of the feed where you want to release the resource.

    
    
  • associated_resource_name(impl Into<String>) / set_associated_resource_name(Option<String>):
    required: true
    

    The name of the resource currently associated with the feed’.

    
    
  • dry_run(bool) / set_dry_run(Option<bool>):
    required: false
    

    Set to true if you want to do a dry run of the disassociate action.

    
    
• On success, responds with DisassociateFeedOutput with field(s):
  • arn(String):

    The ID of the feed where you deleted the associated resource.

  • id(String):

    The ARN of the resource that you deleted.

• On failure, responds with SdkError<DisassociateFeedError>

impl Client

pub fn get_feed(&self) -> GetFeedFluentBuilder

Constructs a fluent builder for the GetFeed operation.

• The fluent builder is configurable:
  • id(impl Into<String>) / set_id(Option<String>):
    required: true
    

    The ID of the feed to query.

    
    
• On success, responds with GetFeedOutput with field(s):
  • arn(String):

    The ARN of the feed.

  • name(String):

    The name of the feed being queried.

  • id(String):

    The ID of the feed being queried.

  • data_endpoints(Vec::<String>):

    The dataEndpoints of the feed being queried.

  • outputs(Vec::<GetOutput>):

    An array of the outputs in the feed being queried.

  • status(FeedStatus):

    The status of the feed being queried.

  • association(Option<FeedAssociation>):

    Information about the resource, if any, associated with the feed being queried.

  • tags(Option<HashMap::<String, String>>):

    A list of the tags, if any, for the feed being queried.

• On failure, responds with SdkError<GetFeedError>

impl Client

pub fn list_feeds(&self) -> ListFeedsFluentBuilder

Constructs a fluent builder for the ListFeeds operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • max_results(i32) / set_max_results(Option<i32>):
    required: false
    

    The maximum number of results to return per API request.

    For example, you submit a list request with MaxResults set at 5. Although 20 items match your request, the service returns no more than the first 5 items. (The service also returns a NextToken value that you can use to fetch the next batch of results.)

    The service might return fewer results than the MaxResults value. If MaxResults is not included in the request, the service defaults to pagination with a maximum of 10 results per page.

    Valid Range: Minimum value of 1. Maximum value of 1000.

    
    
  • next_token(impl Into<String>) / set_next_token(Option<String>):
    required: false
    

    The token that identifies the batch of results that you want to see.

    For example, you submit a ListBridges request with MaxResults set at 5. The service returns the first batch of results (up to 5) and a NextToken value. To see the next batch of results, you can submit the ListBridges request a second time and specify the NextToken value.

    
    
• On success, responds with ListFeedsOutput with field(s):
  • feeds(Vec::<FeedSummary>):

    A list of feed summaries.

  • next_token(Option<String>):

    The token that identifies the batch of results that you want to see. For example, you submit a list request with MaxResults set at 5. The service returns the first batch of results (up to 5) and a NextToken value. To see the next batch of results, you can submit the list request a second time and specify the NextToken value.

• On failure, responds with SdkError<ListFeedsError>

impl Client

pub fn list_tags_for_resource(&self) -> ListTagsForResourceFluentBuilder

Constructs a fluent builder for the ListTagsForResource operation.

• The fluent builder is configurable:
  • resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
    required: true
    

    The ARN of the resource whose tags you want to query.

    
    
• On success, responds with ListTagsForResourceOutput with field(s):
  • tags(Option<HashMap::<String, String>>):

    A list of the tags that belong to this resource.

• On failure, responds with SdkError<ListTagsForResourceError>

impl Client

pub fn tag_resource(&self) -> TagResourceFluentBuilder

Constructs a fluent builder for the TagResource operation.

• The fluent builder is configurable:
  • resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
    required: true
    

    The ARN of the resource where you want to add tags.

    
    
  • tags(impl Into<String>, impl Into<String>) / set_tags(Option<HashMap::<String, String>>):
    required: true
    

    A list of tags to add to the resource.

    
    
• On success, responds with TagResourceOutput
• On failure, responds with SdkError<TagResourceError>

impl Client

pub fn untag_resource(&self) -> UntagResourceFluentBuilder

Constructs a fluent builder for the UntagResource operation.

• The fluent builder is configurable:
  • resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
    required: true
    

    The ARN of the resource where you want to delete one or more tags.

    
    
  • tag_keys(impl Into<String>) / set_tag_keys(Option<Vec::<String>>):
    required: true
    

    The keys of the tags to delete.

    
    
• On success, responds with UntagResourceOutput
• On failure, responds with SdkError<UntagResourceError>

impl Client

pub fn update_feed(&self) -> UpdateFeedFluentBuilder

Constructs a fluent builder for the UpdateFeed operation.

• The fluent builder is configurable:
  • name(impl Into<String>) / set_name(Option<String>):
    required: true
    

    Required. You can specify the existing name (to leave it unchanged) or a new name.

    
    
  • id(impl Into<String>) / set_id(Option<String>):
    required: true
    

    The ID of the feed to update.

    
    
  • outputs(UpdateOutput) / set_outputs(Option<Vec::<UpdateOutput>>):
    required: true
    

    Required. You can specify the existing array of outputs (to leave outputs unchanged) or you can specify a new array.

    
    
• On success, responds with UpdateFeedOutput with field(s):
  • arn(String):

    The ARN of the feed.

  • name(String):

    The updated or original name of the feed.

  • id(String):

    The ID of the feed.

  • data_endpoints(Vec::<String>):

    The data endpoints of the feed.

  • outputs(Vec::<GetOutput>):

    The array of outputs in the feed. You might have left this array unchanged, or you might have changed it.

  • status(FeedStatus):

    The status of the output.

  • association(Option<FeedAssociation>):

    True means that the output was originally created in the feed by the AssociateFeed operation. False means it was created using CreateFeed or UpdateFeed. You will need this value if you use the UpdateFeed operation to modify the list of outputs in the feed.

  • tags(Option<HashMap::<String, String>>):

    The name of the resource currently associated with the feed, if any.

• On failure, responds with SdkError<UpdateFeedError>

impl Client

pub fn from_conf(conf: Config) -> Self

Creates a new client from the service Config.

Panics

This method will panic in the following cases:

• Retries or timeouts are enabled without a sleep_impl configured.
• Identity caching is enabled without a sleep_impl and time_source configured.
• No behavior_version is provided.

The panic message for each of these will have instructions on how to resolve them.

pub fn config(&self) -> &Config

Returns the client’s configuration.

impl Client

pub fn new(sdk_config: &SdkConfig) -> Self

Creates a new client from an SDK Config.

Panics

• This method will panic if the sdk_config is missing an async sleep implementation. If you experience this panic, set the sleep_impl on the Config passed into this function to fix it.
• This method will panic if the sdk_config is missing an HTTP connector. If you experience this panic, set the http_connector on the Config passed into this function to fix it.
• This method will panic if no BehaviorVersion is provided. If you experience this panic, set behavior_version on the Config or enable the behavior-version-latest Cargo feature.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.

impl Waiters for Client

fn wait_until_feed_deleted(&self) -> FeedDeletedFluentBuilder

Wait until a Feed is deleted