Struct rusoto_es::EsClient

pub struct EsClient { /* private fields */ }

A client for the Amazon Elasticsearch Service API.

Implementations

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 accept_inbound_cross_cluster_search_connection<'life0, 'async_trait>(
    &'life0 self,
    input: AcceptInboundCrossClusterSearchConnectionRequest
) -> Pin<Box<dyn Future<Output = Result<AcceptInboundCrossClusterSearchConnectionResponse, RusotoError<AcceptInboundCrossClusterSearchConnectionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Allows the destination domain owner to accept an inbound cross-cluster search connection request.

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 associate_package<'life0, 'async_trait>(
    &'life0 self,
    input: AssociatePackageRequest
) -> Pin<Box<dyn Future<Output = Result<AssociatePackageResponse, RusotoError<AssociatePackageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Associates a package with an Amazon ES domain.

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 create_outbound_cross_cluster_search_connection<'life0, 'async_trait>(
    &'life0 self,
    input: CreateOutboundCrossClusterSearchConnectionRequest
) -> Pin<Box<dyn Future<Output = Result<CreateOutboundCrossClusterSearchConnectionResponse, RusotoError<CreateOutboundCrossClusterSearchConnectionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a new cross-cluster search connection from a source domain to a destination domain.

fn create_package<'life0, 'async_trait>(
    &'life0 self,
    input: CreatePackageRequest
) -> Pin<Box<dyn Future<Output = Result<CreatePackageResponse, RusotoError<CreatePackageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Create a package for use with Amazon ES domains.

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 delete_inbound_cross_cluster_search_connection<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteInboundCrossClusterSearchConnectionRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteInboundCrossClusterSearchConnectionResponse, RusotoError<DeleteInboundCrossClusterSearchConnectionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Allows the destination domain owner to delete an existing inbound cross-cluster search connection.

fn delete_outbound_cross_cluster_search_connection<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteOutboundCrossClusterSearchConnectionRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteOutboundCrossClusterSearchConnectionResponse, RusotoError<DeleteOutboundCrossClusterSearchConnectionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Allows the source domain owner to delete an existing outbound cross-cluster search connection.

fn delete_package<'life0, 'async_trait>(
    &'life0 self,
    input: DeletePackageRequest
) -> Pin<Box<dyn Future<Output = Result<DeletePackageResponse, RusotoError<DeletePackageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Delete the package.

fn describe_domain_auto_tunes<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeDomainAutoTunesRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeDomainAutoTunesResponse, RusotoError<DescribeDomainAutoTunesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Provides scheduled Auto-Tune action details for the Elasticsearch domain, such as Auto-Tune action type, description, severity, and scheduled date.

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_inbound_cross_cluster_search_connections<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeInboundCrossClusterSearchConnectionsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeInboundCrossClusterSearchConnectionsResponse, RusotoError<DescribeInboundCrossClusterSearchConnectionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists all the inbound cross-cluster search connections for a destination domain.

fn describe_outbound_cross_cluster_search_connections<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeOutboundCrossClusterSearchConnectionsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeOutboundCrossClusterSearchConnectionsResponse, RusotoError<DescribeOutboundCrossClusterSearchConnectionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists all the outbound cross-cluster search connections for a source domain.

fn describe_packages<'life0, 'async_trait>(
    &'life0 self,
    input: DescribePackagesRequest
) -> Pin<Box<dyn Future<Output = Result<DescribePackagesResponse, RusotoError<DescribePackagesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Describes all packages available to Amazon ES. Includes options for filtering, limiting the number of results, and pagination.

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 dissociate_package<'life0, 'async_trait>(
    &'life0 self,
    input: DissociatePackageRequest
) -> Pin<Box<dyn Future<Output = Result<DissociatePackageResponse, RusotoError<DissociatePackageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Dissociates a package from the Amazon ES domain.

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_package_version_history<'life0, 'async_trait>(
    &'life0 self,
    input: GetPackageVersionHistoryRequest
) -> Pin<Box<dyn Future<Output = Result<GetPackageVersionHistoryResponse, RusotoError<GetPackageVersionHistoryError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a list of versions of the package, along with their creation time and commit message.

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_domains_for_package<'life0, 'async_trait>(
    &'life0 self,
    input: ListDomainsForPackageRequest
) -> Pin<Box<dyn Future<Output = Result<ListDomainsForPackageResponse, RusotoError<ListDomainsForPackageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists all Amazon ES domains associated with the package.

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_packages_for_domain<'life0, 'async_trait>(
    &'life0 self,
    input: ListPackagesForDomainRequest
) -> Pin<Box<dyn Future<Output = Result<ListPackagesForDomainResponse, RusotoError<ListPackagesForDomainError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Lists all packages associated with the Amazon ES domain.

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 reject_inbound_cross_cluster_search_connection<'life0, 'async_trait>(
    &'life0 self,
    input: RejectInboundCrossClusterSearchConnectionRequest
) -> Pin<Box<dyn Future<Output = Result<RejectInboundCrossClusterSearchConnectionResponse, RusotoError<RejectInboundCrossClusterSearchConnectionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Allows the destination domain owner to reject an inbound cross-cluster search connection request.

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 update_package<'life0, 'async_trait>(
    &'life0 self,
    input: UpdatePackageRequest
) -> Pin<Box<dyn Future<Output = Result<UpdatePackageResponse, RusotoError<UpdatePackageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Updates a package for use with Amazon ES domains.

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.