Struct rusoto_es::EsClient

pub struct EsClient { /* fields omitted */ }

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

pub fn clone(&self) -> EsClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Es for EsClient

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

pub 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

pub 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

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

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

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

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

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

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

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

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

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