Struct rusoto_es::EsClient

pub struct EsClient { /* fields omitted */ }

A client for the Amazon Elasticsearch Service API.

Methods

impl EsClient

pub fn new(region: Region) -> EsClient

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
) -> EsClient where
    P: ProvideAwsCredentials + Send + Sync + 'static,
    D: DispatchSignedRequest + Send + Sync + 'static, 

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

Trait Implementations

impl Clone for EsClient

fn clone(&self) -> EsClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Es for EsClient

fn add_tags<'life0, 'async_trait>(
    &'life0 self,
    input: AddTagsRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<AddTagsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Attaches tags to an existing Elasticsearch domain. Tags are a set of case-sensitive key value pairs. An Elasticsearch domain may have up to 10 tags. See Tagging Amazon Elasticsearch Service Domains for more information.

fn cancel_elasticsearch_service_software_update<'life0, 'async_trait>(
    &'life0 self,
    input: CancelElasticsearchServiceSoftwareUpdateRequest
) -> Pin<Box<dyn Future<Output = Result<CancelElasticsearchServiceSoftwareUpdateResponse, RusotoError<CancelElasticsearchServiceSoftwareUpdateError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Cancels a scheduled service software update for an Amazon ES domain. You can only perform this operation before the AutomatedUpdateDate and when the UpdateStatus is in the PENDING_UPDATE state.

fn create_elasticsearch_domain<'life0, 'async_trait>(
    &'life0 self,
    input: CreateElasticsearchDomainRequest
) -> Pin<Box<dyn Future<Output = Result<CreateElasticsearchDomainResponse, RusotoError<CreateElasticsearchDomainError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a new Elasticsearch domain. For more information, see Creating Elasticsearch Domains in the Amazon Elasticsearch Service Developer Guide.

fn delete_elasticsearch_domain<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteElasticsearchDomainRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteElasticsearchDomainResponse, RusotoError<DeleteElasticsearchDomainError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Permanently deletes the specified Elasticsearch domain and all of its data. Once a domain is deleted, it cannot be recovered.

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

Deletes the service-linked role that Elasticsearch Service uses to manage and maintain VPC domains. Role deletion will fail if any existing VPC domains use the role. You must delete any such Elasticsearch domains before deleting the role. See Deleting Elasticsearch Service Role in VPC Endpoints for Amazon Elasticsearch Service Domains.

fn describe_elasticsearch_domain<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeElasticsearchDomainRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeElasticsearchDomainResponse, RusotoError<DescribeElasticsearchDomainError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns domain configuration information about the specified Elasticsearch domain, including the domain ID, domain endpoint, and domain ARN.

fn describe_elasticsearch_domain_config<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeElasticsearchDomainConfigRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeElasticsearchDomainConfigResponse, RusotoError<DescribeElasticsearchDomainConfigError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Provides cluster configuration information about the specified Elasticsearch domain, such as the state, creation date, update version, and update date for cluster options.

fn describe_elasticsearch_domains<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeElasticsearchDomainsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeElasticsearchDomainsResponse, RusotoError<DescribeElasticsearchDomainsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns domain configuration information about the specified Elasticsearch domains, including the domain ID, domain endpoint, and domain ARN.

fn describe_elasticsearch_instance_type_limits<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeElasticsearchInstanceTypeLimitsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeElasticsearchInstanceTypeLimitsResponse, RusotoError<DescribeElasticsearchInstanceTypeLimitsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Describe Elasticsearch Limits for a given InstanceType and ElasticsearchVersion. When modifying existing Domain, specify the DomainName to know what Limits are supported for modifying.

fn describe_reserved_elasticsearch_instance_offerings<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeReservedElasticsearchInstanceOfferingsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeReservedElasticsearchInstanceOfferingsResponse, RusotoError<DescribeReservedElasticsearchInstanceOfferingsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists available reserved Elasticsearch instance offerings.

fn describe_reserved_elasticsearch_instances<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeReservedElasticsearchInstancesRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeReservedElasticsearchInstancesResponse, RusotoError<DescribeReservedElasticsearchInstancesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns information about reserved Elasticsearch instances for this account.

fn get_compatible_elasticsearch_versions<'life0, 'async_trait>(
    &'life0 self,
    input: GetCompatibleElasticsearchVersionsRequest
) -> Pin<Box<dyn Future<Output = Result<GetCompatibleElasticsearchVersionsResponse, RusotoError<GetCompatibleElasticsearchVersionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a list of upgrade compatible Elastisearch versions. You can optionally pass a DomainName to get all upgrade compatible Elasticsearch versions for that specific domain.

fn get_upgrade_history<'life0, 'async_trait>(
    &'life0 self,
    input: GetUpgradeHistoryRequest
) -> Pin<Box<dyn Future<Output = Result<GetUpgradeHistoryResponse, RusotoError<GetUpgradeHistoryError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves the complete history of the last 10 upgrades that were performed on the domain.

fn get_upgrade_status<'life0, 'async_trait>(
    &'life0 self,
    input: GetUpgradeStatusRequest
) -> Pin<Box<dyn Future<Output = Result<GetUpgradeStatusResponse, RusotoError<GetUpgradeStatusError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Retrieves the latest status of the last upgrade or upgrade eligibility check that was performed on the domain.

fn list_domain_names<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<ListDomainNamesResponse, RusotoError<ListDomainNamesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns the name of all Elasticsearch domains owned by the current user's account.

fn list_elasticsearch_instance_types<'life0, 'async_trait>(
    &'life0 self,
    input: ListElasticsearchInstanceTypesRequest
) -> Pin<Box<dyn Future<Output = Result<ListElasticsearchInstanceTypesResponse, RusotoError<ListElasticsearchInstanceTypesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

List all Elasticsearch instance types that are supported for given ElasticsearchVersion

fn list_elasticsearch_versions<'life0, 'async_trait>(
    &'life0 self,
    input: ListElasticsearchVersionsRequest
) -> Pin<Box<dyn Future<Output = Result<ListElasticsearchVersionsResponse, RusotoError<ListElasticsearchVersionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

List all supported Elasticsearch versions

fn list_tags<'life0, 'async_trait>(
    &'life0 self,
    input: ListTagsRequest
) -> Pin<Box<dyn Future<Output = Result<ListTagsResponse, RusotoError<ListTagsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns all tags for the given Elasticsearch domain.

fn purchase_reserved_elasticsearch_instance_offering<'life0, 'async_trait>(
    &'life0 self,
    input: PurchaseReservedElasticsearchInstanceOfferingRequest
) -> Pin<Box<dyn Future<Output = Result<PurchaseReservedElasticsearchInstanceOfferingResponse, RusotoError<PurchaseReservedElasticsearchInstanceOfferingError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Allows you to purchase reserved Elasticsearch instances.

fn remove_tags<'life0, 'async_trait>(
    &'life0 self,
    input: RemoveTagsRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<RemoveTagsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Removes the specified set of tags from the specified Elasticsearch domain.

fn start_elasticsearch_service_software_update<'life0, 'async_trait>(
    &'life0 self,
    input: StartElasticsearchServiceSoftwareUpdateRequest
) -> Pin<Box<dyn Future<Output = Result<StartElasticsearchServiceSoftwareUpdateResponse, RusotoError<StartElasticsearchServiceSoftwareUpdateError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Schedules a service software update for an Amazon ES domain.

fn update_elasticsearch_domain_config<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateElasticsearchDomainConfigRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateElasticsearchDomainConfigResponse, RusotoError<UpdateElasticsearchDomainConfigError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Modifies the cluster configuration of the specified Elasticsearch domain, setting as setting the instance type and the number of instances.

fn upgrade_elasticsearch_domain<'life0, 'async_trait>(
    &'life0 self,
    input: UpgradeElasticsearchDomainRequest
) -> Pin<Box<dyn Future<Output = Result<UpgradeElasticsearchDomainResponse, RusotoError<UpgradeElasticsearchDomainError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Allows you to either upgrade your domain or perform an Upgrade eligibility check to a compatible Elasticsearch version.