Struct aws_sdk_opensearch::Client
source · [−]pub struct Client { /* private fields */ }Expand description
Client for Amazon OpenSearch Service
Client for invoking operations on Amazon OpenSearch Service. Each operation on Amazon OpenSearch Service is a method on this
this struct. .send() MUST be invoked on the generated operations to dispatch the request to the service.
Examples
Constructing a client and invoking an operation
// create a shared configuration. This can be used & shared between multiple service clients.
let shared_config = aws_config::load_from_env().await;
let client = aws_sdk_opensearch::Client::new(&shared_config);
// invoke an operation
/* let rsp = client
.<operation_name>().
.<param>("some value")
.send().await; */Constructing a client with custom configuration
use aws_config::RetryConfig;
let shared_config = aws_config::load_from_env().await;
let config = aws_sdk_opensearch::config::Builder::from(&shared_config)
.retry_config(RetryConfig::disabled())
.build();
let client = aws_sdk_opensearch::Client::from_conf(config);Implementations
sourceimpl Client
impl Client
sourcepub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self
pub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self
Creates a client with the given service configuration.
sourceimpl Client
impl Client
sourcepub fn accept_inbound_connection(&self) -> AcceptInboundConnection
pub fn accept_inbound_connection(&self) -> AcceptInboundConnection
Constructs a fluent builder for the AcceptInboundConnection operation.
- The fluent builder is configurable:
connection_id(impl Into<String>)/set_connection_id(Option<String>):The ID of the inbound connection you want to accept.
- On success, responds with
AcceptInboundConnectionOutputwith field(s):connection(Option<InboundConnection>):The
of the accepted inbound connection.InboundConnection
- On failure, responds with
SdkError<AcceptInboundConnectionError>
Constructs a fluent builder for the AddTags operation.
- The fluent builder is configurable:
arn(impl Into<String>)/set_arn(Option<String>):Specify the
ARNof the domain you want to add tags to.tag_list(Vec<Tag>)/set_tag_list(Option<Vec<Tag>>):List of
Tagto add to the domain.
- On success, responds with
AddTagsOutput - On failure, responds with
SdkError<AddTagsError>
sourcepub fn associate_package(&self) -> AssociatePackage
pub fn associate_package(&self) -> AssociatePackage
Constructs a fluent builder for the AssociatePackage operation.
- The fluent builder is configurable:
package_id(impl Into<String>)/set_package_id(Option<String>):Internal ID of the package to associate with a domain. Use
DescribePackagesto find this value.domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain to associate the package with.
- On success, responds with
AssociatePackageOutputwith field(s):domain_package_details(Option<DomainPackageDetails>):DomainPackageDetails
- On failure, responds with
SdkError<AssociatePackageError>
sourcepub fn cancel_service_software_update(&self) -> CancelServiceSoftwareUpdate
pub fn cancel_service_software_update(&self) -> CancelServiceSoftwareUpdate
Constructs a fluent builder for the CancelServiceSoftwareUpdate operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain that you want to stop the latest service software update on.
- On success, responds with
CancelServiceSoftwareUpdateOutputwith field(s):service_software_options(Option<ServiceSoftwareOptions>):The current status of the OpenSearch service software update.
- On failure, responds with
SdkError<CancelServiceSoftwareUpdateError>
sourcepub fn create_domain(&self) -> CreateDomain
pub fn create_domain(&self) -> CreateDomain
Constructs a fluent builder for the CreateDomain operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the Amazon OpenSearch Service domain you’re creating. Domain names are unique across the domains owned by an account within an AWS region. Domain names must start with a lowercase letter and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
engine_version(impl Into<String>)/set_engine_version(Option<String>):String of format Elasticsearch_X.Y or OpenSearch_X.Y to specify the engine version for the Amazon OpenSearch Service domain. For example, “OpenSearch_1.0” or “Elasticsearch_7.9”. For more information, see Creating and managing Amazon OpenSearch Service domains .
cluster_config(ClusterConfig)/set_cluster_config(Option<ClusterConfig>):Configuration options for a domain. Specifies the instance type and number of instances in the domain.
ebs_options(EbsOptions)/set_ebs_options(Option<EbsOptions>):Options to enable, disable, and specify the type and size of EBS storage volumes.
access_policies(impl Into<String>)/set_access_policies(Option<String>):IAM access policy as a JSON-formatted string.
snapshot_options(SnapshotOptions)/set_snapshot_options(Option<SnapshotOptions>):Option to set time, in UTC format, of the daily automated snapshot. Default value is 0 hours.
vpc_options(VpcOptions)/set_vpc_options(Option<VpcOptions>):Options to specify the subnets and security groups for a VPC endpoint. For more information, see Launching your Amazon OpenSearch Service domains using a VPC .
cognito_options(CognitoOptions)/set_cognito_options(Option<CognitoOptions>):Options to specify the Cognito user and identity pools for OpenSearch Dashboards authentication. For more information, see Configuring Amazon Cognito authentication for OpenSearch Dashboards.
encryption_at_rest_options(EncryptionAtRestOptions)/set_encryption_at_rest_options(Option<EncryptionAtRestOptions>):Options for encryption of data at rest.
node_to_node_encryption_options(NodeToNodeEncryptionOptions)/set_node_to_node_encryption_options(Option<NodeToNodeEncryptionOptions>):Node-to-node encryption options.
advanced_options(HashMap<String, String>)/set_advanced_options(Option<HashMap<String, String>>):Option to allow references to indices in an HTTP request body. Must be
falsewhen configuring access to individual sub-resources. By default, the value istrue. See Advanced cluster parameters for more information.log_publishing_options(HashMap<LogType, LogPublishingOption>)/set_log_publishing_options(Option<HashMap<LogType, LogPublishingOption>>):Map of
LogTypeandLogPublishingOption, each containing options to publish a given type of OpenSearch log.domain_endpoint_options(DomainEndpointOptions)/set_domain_endpoint_options(Option<DomainEndpointOptions>):Options to specify configurations that will be applied to the domain endpoint.
advanced_security_options(AdvancedSecurityOptionsInput)/set_advanced_security_options(Option<AdvancedSecurityOptionsInput>):Specifies advanced security options.
tag_list(Vec<Tag>)/set_tag_list(Option<Vec<Tag>>):A list of
Tagadded during domain creation.auto_tune_options(AutoTuneOptionsInput)/set_auto_tune_options(Option<AutoTuneOptionsInput>):Specifies Auto-Tune options.
- On success, responds with
CreateDomainOutputwith field(s):domain_status(Option<DomainStatus>):The status of the newly created domain.
- On failure, responds with
SdkError<CreateDomainError>
sourcepub fn create_outbound_connection(&self) -> CreateOutboundConnection
pub fn create_outbound_connection(&self) -> CreateOutboundConnection
Constructs a fluent builder for the CreateOutboundConnection operation.
- The fluent builder is configurable:
local_domain_info(DomainInformationContainer)/set_local_domain_info(Option<DomainInformationContainer>):The
for the local OpenSearch domain.AWSDomainInformationremote_domain_info(DomainInformationContainer)/set_remote_domain_info(Option<DomainInformationContainer>):The
for the remote OpenSearch domain.AWSDomainInformationconnection_alias(impl Into<String>)/set_connection_alias(Option<String>):The connection alias used used by the customer for this cross-cluster connection.
- On success, responds with
CreateOutboundConnectionOutputwith field(s):local_domain_info(Option<DomainInformationContainer>):The
for the local OpenSearch domain.AWSDomainInformationremote_domain_info(Option<DomainInformationContainer>):The
for the remote OpenSearch domain.AWSDomainInformationconnection_alias(Option<String>):The connection alias provided during the create connection request.
connection_status(Option<OutboundConnectionStatus>):The
for the newly created connection.OutboundConnectionStatusconnection_id(Option<String>):The unique ID for the created outbound connection, which is used for subsequent operations on the connection.
- On failure, responds with
SdkError<CreateOutboundConnectionError>
sourcepub fn create_package(&self) -> CreatePackage
pub fn create_package(&self) -> CreatePackage
Constructs a fluent builder for the CreatePackage operation.
- The fluent builder is configurable:
package_name(impl Into<String>)/set_package_name(Option<String>):Unique identifier for the package.
package_type(PackageType)/set_package_type(Option<PackageType>):Type of package. Currently supports only TXT-DICTIONARY.
package_description(impl Into<String>)/set_package_description(Option<String>):Description of the package.
package_source(PackageSource)/set_package_source(Option<PackageSource>):The Amazon S3 location from which to import the package.
- On success, responds with
CreatePackageOutputwith field(s):package_details(Option<PackageDetails>):Information about the package.
- On failure, responds with
SdkError<CreatePackageError>
sourcepub fn delete_domain(&self) -> DeleteDomain
pub fn delete_domain(&self) -> DeleteDomain
Constructs a fluent builder for the DeleteDomain operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain you want to permanently delete.
- On success, responds with
DeleteDomainOutputwith field(s):domain_status(Option<DomainStatus>):The status of the domain being deleted.
- On failure, responds with
SdkError<DeleteDomainError>
sourcepub fn delete_inbound_connection(&self) -> DeleteInboundConnection
pub fn delete_inbound_connection(&self) -> DeleteInboundConnection
Constructs a fluent builder for the DeleteInboundConnection operation.
- The fluent builder is configurable:
connection_id(impl Into<String>)/set_connection_id(Option<String>):The ID of the inbound connection to permanently delete.
- On success, responds with
DeleteInboundConnectionOutputwith field(s):connection(Option<InboundConnection>):The
of the deleted inbound connection.InboundConnection
- On failure, responds with
SdkError<DeleteInboundConnectionError>
sourcepub fn delete_outbound_connection(&self) -> DeleteOutboundConnection
pub fn delete_outbound_connection(&self) -> DeleteOutboundConnection
Constructs a fluent builder for the DeleteOutboundConnection operation.
- The fluent builder is configurable:
connection_id(impl Into<String>)/set_connection_id(Option<String>):The ID of the outbound connection you want to permanently delete.
- On success, responds with
DeleteOutboundConnectionOutputwith field(s):connection(Option<OutboundConnection>):The
of the deleted outbound connection.OutboundConnection
- On failure, responds with
SdkError<DeleteOutboundConnectionError>
sourcepub fn delete_package(&self) -> DeletePackage
pub fn delete_package(&self) -> DeletePackage
Constructs a fluent builder for the DeletePackage operation.
- The fluent builder is configurable:
package_id(impl Into<String>)/set_package_id(Option<String>):The internal ID of the package you want to delete. Use
DescribePackagesto find this value.
- On success, responds with
DeletePackageOutputwith field(s):package_details(Option<PackageDetails>):PackageDetails
- On failure, responds with
SdkError<DeletePackageError>
sourcepub fn describe_domain(&self) -> DescribeDomain
pub fn describe_domain(&self) -> DescribeDomain
Constructs a fluent builder for the DescribeDomain operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain for which you want information.
- On success, responds with
DescribeDomainOutputwith field(s):domain_status(Option<DomainStatus>):The current status of the domain.
- On failure, responds with
SdkError<DescribeDomainError>
sourcepub fn describe_domain_auto_tunes(&self) -> DescribeDomainAutoTunes
pub fn describe_domain_auto_tunes(&self) -> DescribeDomainAutoTunes
Constructs a fluent builder for the DescribeDomainAutoTunes operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The domain name for which you want Auto-Tune action details.
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned. If not specified, defaults to 100.
next_token(impl Into<String>)/set_next_token(Option<String>):NextToken is sent in case the earlier API call results contain the NextToken. Used for pagination.
- On success, responds with
DescribeDomainAutoTunesOutputwith field(s):auto_tunes(Option<Vec<AutoTune>>):The list of setting adjustments that Auto-Tune has made to the domain. See Auto-Tune for Amazon OpenSearch Service for more information.
next_token(Option<String>):An identifier to allow retrieval of paginated results.
- On failure, responds with
SdkError<DescribeDomainAutoTunesError>
sourcepub fn describe_domain_change_progress(&self) -> DescribeDomainChangeProgress
pub fn describe_domain_change_progress(&self) -> DescribeDomainChangeProgress
Constructs a fluent builder for the DescribeDomainChangeProgress operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The domain you want to get the progress information about.
change_id(impl Into<String>)/set_change_id(Option<String>):The specific change ID for which you want to get progress information. This is an optional parameter. If omitted, the service returns information about the most recent configuration change.
- On success, responds with
DescribeDomainChangeProgressOutputwith field(s):change_progress_status(Option<ChangeProgressStatusDetails>):Progress information for the configuration change that is requested in the
DescribeDomainChangeProgressrequest.
- On failure, responds with
SdkError<DescribeDomainChangeProgressError>
sourcepub fn describe_domain_config(&self) -> DescribeDomainConfig
pub fn describe_domain_config(&self) -> DescribeDomainConfig
Constructs a fluent builder for the DescribeDomainConfig operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The domain you want to get information about.
- On success, responds with
DescribeDomainConfigOutputwith field(s):domain_config(Option<DomainConfig>):The configuration information of the domain requested in the
DescribeDomainConfigrequest.
- On failure, responds with
SdkError<DescribeDomainConfigError>
sourcepub fn describe_domains(&self) -> DescribeDomains
pub fn describe_domains(&self) -> DescribeDomains
Constructs a fluent builder for the DescribeDomains operation.
- The fluent builder is configurable:
domain_names(Vec<String>)/set_domain_names(Option<Vec<String>>):The domains for which you want information.
- On success, responds with
DescribeDomainsOutputwith field(s):domain_status_list(Option<Vec<DomainStatus>>):The status of the domains requested in the
DescribeDomainsrequest.
- On failure, responds with
SdkError<DescribeDomainsError>
sourcepub fn describe_inbound_connections(&self) -> DescribeInboundConnections
pub fn describe_inbound_connections(&self) -> DescribeInboundConnections
Constructs a fluent builder for the DescribeInboundConnections operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
filters(Vec<Filter>)/set_filters(Option<Vec<Filter>>):A list of filters used to match properties for inbound cross-cluster connections. Available
values are:Filter- connection-id
- local-domain-info.domain-name
- local-domain-info.owner-id
- local-domain-info.region
- remote-domain-info.domain-name
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned. If not specified, defaults to 100.
next_token(impl Into<String>)/set_next_token(Option<String>):If more results are available and NextToken is present, make the next request to the same API with the received NextToken to paginate the remaining results.
- On success, responds with
DescribeInboundConnectionsOutputwith field(s):connections(Option<Vec<InboundConnection>>):A list of
matching the specified filter criteria.InboundConnectionnext_token(Option<String>):If more results are available and NextToken is present, make the next request to the same API with the received NextToken to paginate the remaining results.
- On failure, responds with
SdkError<DescribeInboundConnectionsError>
sourcepub fn describe_instance_type_limits(&self) -> DescribeInstanceTypeLimits
pub fn describe_instance_type_limits(&self) -> DescribeInstanceTypeLimits
Constructs a fluent builder for the DescribeInstanceTypeLimits operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain you want to modify. Only include this value if you’re querying OpenSearch
for an existing domain.Limitsinstance_type(OpenSearchPartitionInstanceType)/set_instance_type(Option<OpenSearchPartitionInstanceType>):The instance type for an OpenSearch cluster for which OpenSearch
are needed.Limitsengine_version(impl Into<String>)/set_engine_version(Option<String>):Version of OpenSearch for which
are needed.Limits
- On success, responds with
DescribeInstanceTypeLimitsOutputwith field(s):limits_by_role(Option<HashMap<String, Limits>>):The role of a given instance and all applicable limits. The role performed by a given OpenSearch instance can be one of the following:
- data: If the given InstanceType is used as a data node
- master: If the given InstanceType is used as a master node
- ultra_warm: If the given InstanceType is used as a warm node
- On failure, responds with
SdkError<DescribeInstanceTypeLimitsError>
sourcepub fn describe_outbound_connections(&self) -> DescribeOutboundConnections
pub fn describe_outbound_connections(&self) -> DescribeOutboundConnections
Constructs a fluent builder for the DescribeOutboundConnections operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
filters(Vec<Filter>)/set_filters(Option<Vec<Filter>>):A list of filters used to match properties for outbound cross-cluster connections. Available
names for this operation are:Filter- connection-id
- remote-domain-info.domain-name
- remote-domain-info.owner-id
- remote-domain-info.region
- local-domain-info.domain-name
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned. If not specified, defaults to 100.
next_token(impl Into<String>)/set_next_token(Option<String>):NextToken is sent in case the earlier API call results contain the NextToken parameter. Used for pagination.
- On success, responds with
DescribeOutboundConnectionsOutputwith field(s):connections(Option<Vec<OutboundConnection>>):A list of
matching the specified filter criteria.OutboundConnectionnext_token(Option<String>):If more results are available and NextToken is present, make the next request to the same API with the received NextToken to paginate the remaining results.
- On failure, responds with
SdkError<DescribeOutboundConnectionsError>
sourcepub fn describe_packages(&self) -> DescribePackages
pub fn describe_packages(&self) -> DescribePackages
Constructs a fluent builder for the DescribePackages operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
filters(Vec<DescribePackagesFilter>)/set_filters(Option<Vec<DescribePackagesFilter>>):Only returns packages that match the
DescribePackagesFilterListvalues.max_results(i32)/set_max_results(i32):Limits results to a maximum number of packages.
next_token(impl Into<String>)/set_next_token(Option<String>):Used for pagination. Only necessary if a previous API call includes a non-null NextToken value. If provided, returns results for the next page.
- On success, responds with
DescribePackagesOutputwith field(s):package_details_list(Option<Vec<PackageDetails>>):List of
PackageDetailsobjects.next_token(Option<String>): (undocumented)
- On failure, responds with
SdkError<DescribePackagesError>
sourcepub fn describe_reserved_instance_offerings(
&self
) -> DescribeReservedInstanceOfferings
pub fn describe_reserved_instance_offerings(
&self
) -> DescribeReservedInstanceOfferings
Constructs a fluent builder for the DescribeReservedInstanceOfferings operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
reserved_instance_offering_id(impl Into<String>)/set_reserved_instance_offering_id(Option<String>):The offering identifier filter value. Use this parameter to show only the available offering that matches the specified reservation identifier.
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned. If not specified, defaults to 100.
next_token(impl Into<String>)/set_next_token(Option<String>):Provides an identifier to allow retrieval of paginated results.
- On success, responds with
DescribeReservedInstanceOfferingsOutputwith field(s):next_token(Option<String>):Provides an identifier to allow retrieval of paginated results.
reserved_instance_offerings(Option<Vec<ReservedInstanceOffering>>):List of reserved OpenSearch instance offerings
- On failure, responds with
SdkError<DescribeReservedInstanceOfferingsError>
sourcepub fn describe_reserved_instances(&self) -> DescribeReservedInstances
pub fn describe_reserved_instances(&self) -> DescribeReservedInstances
Constructs a fluent builder for the DescribeReservedInstances operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
reserved_instance_id(impl Into<String>)/set_reserved_instance_id(Option<String>):The reserved instance identifier filter value. Use this parameter to show only the reservation that matches the specified reserved OpenSearch instance ID.
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned. If not specified, defaults to 100.
next_token(impl Into<String>)/set_next_token(Option<String>):Provides an identifier to allow retrieval of paginated results.
- On success, responds with
DescribeReservedInstancesOutputwith field(s):next_token(Option<String>):Provides an identifier to allow retrieval of paginated results.
reserved_instances(Option<Vec<ReservedInstance>>):List of reserved OpenSearch instances.
- On failure, responds with
SdkError<DescribeReservedInstancesError>
sourcepub fn dissociate_package(&self) -> DissociatePackage
pub fn dissociate_package(&self) -> DissociatePackage
Constructs a fluent builder for the DissociatePackage operation.
- The fluent builder is configurable:
package_id(impl Into<String>)/set_package_id(Option<String>):The internal ID of the package to associate with a domain. Use
DescribePackagesto find this value.domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain to associate the package with.
- On success, responds with
DissociatePackageOutputwith field(s):domain_package_details(Option<DomainPackageDetails>):DomainPackageDetails
- On failure, responds with
SdkError<DissociatePackageError>
sourcepub fn get_compatible_versions(&self) -> GetCompatibleVersions
pub fn get_compatible_versions(&self) -> GetCompatibleVersions
Constructs a fluent builder for the GetCompatibleVersions operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of an domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
- On success, responds with
GetCompatibleVersionsOutputwith field(s):compatible_versions(Option<Vec<CompatibleVersionsMap>>):A map of compatible OpenSearch versions returned as part of the
operation.GetCompatibleVersions
- On failure, responds with
SdkError<GetCompatibleVersionsError>
sourcepub fn get_package_version_history(&self) -> GetPackageVersionHistory
pub fn get_package_version_history(&self) -> GetPackageVersionHistory
Constructs a fluent builder for the GetPackageVersionHistory operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
package_id(impl Into<String>)/set_package_id(Option<String>):Returns an audit history of package versions.
max_results(i32)/set_max_results(i32):Limits results to a maximum number of package versions.
next_token(impl Into<String>)/set_next_token(Option<String>):Used for pagination. Only necessary if a previous API call includes a non-null NextToken value. If provided, returns results for the next page.
- On success, responds with
GetPackageVersionHistoryOutputwith field(s):package_id(Option<String>): (undocumented)package_version_history_list(Option<Vec<PackageVersionHistory>>):List of
PackageVersionHistoryobjects.next_token(Option<String>): (undocumented)
- On failure, responds with
SdkError<GetPackageVersionHistoryError>
sourcepub fn get_upgrade_history(&self) -> GetUpgradeHistory
pub fn get_upgrade_history(&self) -> GetUpgradeHistory
Constructs a fluent builder for the GetUpgradeHistory operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of an domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned.
next_token(impl Into<String>)/set_next_token(Option<String>):Paginated APIs accept the NextToken input to return the next page of results and provide a NextToken output in the response, which you can use to retrieve more results.
- On success, responds with
GetUpgradeHistoryOutputwith field(s):upgrade_histories(Option<Vec<UpgradeHistory>>):A list of
objects corresponding to each upgrade or upgrade eligibility check performed on a domain returned as part of theUpgradeHistoryobject.GetUpgradeHistoryResponsenext_token(Option<String>):Pagination token that needs to be supplied to the next call to get the next page of results.
- On failure, responds with
SdkError<GetUpgradeHistoryError>
sourcepub fn get_upgrade_status(&self) -> GetUpgradeStatus
pub fn get_upgrade_status(&self) -> GetUpgradeStatus
Constructs a fluent builder for the GetUpgradeStatus operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of an domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
- On success, responds with
GetUpgradeStatusOutputwith field(s):upgrade_step(Option<UpgradeStep>):One of three steps an upgrade or upgrade eligibility check goes through:
- PreUpgradeCheck
- Snapshot
- Upgrade
step_status(Option<UpgradeStatus>):One of four statuses an upgrade have, returned as part of the
object. The status can take one of the following values:GetUpgradeStatusResponse- In Progress
- Succeeded
- Succeeded with Issues
- Failed
upgrade_name(Option<String>):A string that briefly describes the update.
- On failure, responds with
SdkError<GetUpgradeStatusError>
sourcepub fn list_domain_names(&self) -> ListDomainNames
pub fn list_domain_names(&self) -> ListDomainNames
Constructs a fluent builder for the ListDomainNames operation.
- The fluent builder is configurable:
engine_type(EngineType)/set_engine_type(Option<EngineType>):Optional parameter to filter the output by domain engine type. Acceptable values are ‘Elasticsearch’ and ‘OpenSearch’.
- On success, responds with
ListDomainNamesOutputwith field(s):domain_names(Option<Vec<DomainInfo>>):List of domain names and respective engine types.
- On failure, responds with
SdkError<ListDomainNamesError>
sourcepub fn list_domains_for_package(&self) -> ListDomainsForPackage
pub fn list_domains_for_package(&self) -> ListDomainsForPackage
Constructs a fluent builder for the ListDomainsForPackage operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
package_id(impl Into<String>)/set_package_id(Option<String>):The package for which to list associated domains.
max_results(i32)/set_max_results(i32):Limits the results to a maximum number of domains.
next_token(impl Into<String>)/set_next_token(Option<String>):Used for pagination. Only necessary if a previous API call includes a non-null NextToken value. If provided, returns results for the next page.
- On success, responds with
ListDomainsForPackageOutputwith field(s):domain_package_details_list(Option<Vec<DomainPackageDetails>>):List of
DomainPackageDetailsobjects.next_token(Option<String>): (undocumented)
- On failure, responds with
SdkError<ListDomainsForPackageError>
sourcepub fn list_instance_type_details(&self) -> ListInstanceTypeDetails
pub fn list_instance_type_details(&self) -> ListInstanceTypeDetails
Constructs a fluent builder for the ListInstanceTypeDetails operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
engine_version(impl Into<String>)/set_engine_version(Option<String>): (undocumented)domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of an domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned.
next_token(impl Into<String>)/set_next_token(Option<String>):Paginated APIs accept the NextToken input to return the next page of results and provide a NextToken output in the response, which you can use to retrieve more results.
- On success, responds with
ListInstanceTypeDetailsOutputwith field(s):instance_type_details(Option<Vec<InstanceTypeDetails>>): (undocumented)next_token(Option<String>):Paginated APIs accept the NextToken input to return the next page of results and provide a NextToken output in the response, which you can use to retrieve more results.
- On failure, responds with
SdkError<ListInstanceTypeDetailsError>
sourcepub fn list_packages_for_domain(&self) -> ListPackagesForDomain
pub fn list_packages_for_domain(&self) -> ListPackagesForDomain
Constructs a fluent builder for the ListPackagesForDomain operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain for which you want to list associated packages.
max_results(i32)/set_max_results(i32):Limits results to a maximum number of packages.
next_token(impl Into<String>)/set_next_token(Option<String>):Used for pagination. Only necessary if a previous API call includes a non-null NextToken value. If provided, returns results for the next page.
- On success, responds with
ListPackagesForDomainOutputwith field(s):domain_package_details_list(Option<Vec<DomainPackageDetails>>):List of
DomainPackageDetailsobjects.next_token(Option<String>):Pagination token to supply to the next call to get the next page of results.
- On failure, responds with
SdkError<ListPackagesForDomainError>
Constructs a fluent builder for the ListTags operation.
- The fluent builder is configurable:
arn(impl Into<String>)/set_arn(Option<String>):Specify the
ARNof the domain that the tags you want to view are attached to.
- On success, responds with
ListTagsOutputwith field(s):tag_list(Option<Vec<Tag>>):List of
Tagfor the requested domain.
- On failure, responds with
SdkError<ListTagsError>
sourcepub fn list_versions(&self) -> ListVersions
pub fn list_versions(&self) -> ListVersions
Constructs a fluent builder for the ListVersions operation.
This operation supports pagination; See into_paginator().
- The fluent builder is configurable:
max_results(i32)/set_max_results(i32):Set this value to limit the number of results returned. Value must be greater than 10 or it won’t be honored.
next_token(impl Into<String>)/set_next_token(Option<String>):Paginated APIs accept the NextToken input to return the next page of results and provide a NextToken output in the response, which you can use to retrieve more results.
- On success, responds with
ListVersionsOutputwith field(s):versions(Option<Vec<String>>):List of supported OpenSearch versions.
next_token(Option<String>):Paginated APIs accept the NextToken input to return the next page of results and provide a NextToken output in the response, which you can use to retrieve more results.
- On failure, responds with
SdkError<ListVersionsError>
sourcepub fn purchase_reserved_instance_offering(
&self
) -> PurchaseReservedInstanceOffering
pub fn purchase_reserved_instance_offering(
&self
) -> PurchaseReservedInstanceOffering
Constructs a fluent builder for the PurchaseReservedInstanceOffering operation.
- The fluent builder is configurable:
reserved_instance_offering_id(impl Into<String>)/set_reserved_instance_offering_id(Option<String>):The ID of the reserved OpenSearch instance offering to purchase.
reservation_name(impl Into<String>)/set_reservation_name(Option<String>):A customer-specified identifier to track this reservation.
instance_count(i32)/set_instance_count(i32):The number of OpenSearch instances to reserve.
- On success, responds with
PurchaseReservedInstanceOfferingOutputwith field(s):reserved_instance_id(Option<String>):Details of the reserved OpenSearch instance which was purchased.
reservation_name(Option<String>):The customer-specified identifier used to track this reservation.
- On failure, responds with
SdkError<PurchaseReservedInstanceOfferingError>
sourcepub fn reject_inbound_connection(&self) -> RejectInboundConnection
pub fn reject_inbound_connection(&self) -> RejectInboundConnection
Constructs a fluent builder for the RejectInboundConnection operation.
- The fluent builder is configurable:
connection_id(impl Into<String>)/set_connection_id(Option<String>):The ID of the inbound connection to reject.
- On success, responds with
RejectInboundConnectionOutputwith field(s):connection(Option<InboundConnection>):The
of the rejected inbound connection.InboundConnection
- On failure, responds with
SdkError<RejectInboundConnectionError>
Constructs a fluent builder for the RemoveTags operation.
- The fluent builder is configurable:
arn(impl Into<String>)/set_arn(Option<String>):The
ARNof the domain from which you want to delete the specified tags.tag_keys(Vec<String>)/set_tag_keys(Option<Vec<String>>):The
TagKeylist you want to remove from the domain.
- On success, responds with
RemoveTagsOutput - On failure, responds with
SdkError<RemoveTagsError>
sourcepub fn start_service_software_update(&self) -> StartServiceSoftwareUpdate
pub fn start_service_software_update(&self) -> StartServiceSoftwareUpdate
Constructs a fluent builder for the StartServiceSoftwareUpdate operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain that you want to update to the latest service software.
- On success, responds with
StartServiceSoftwareUpdateOutputwith field(s):service_software_options(Option<ServiceSoftwareOptions>):The current status of the OpenSearch service software update.
- On failure, responds with
SdkError<StartServiceSoftwareUpdateError>
sourcepub fn update_domain_config(&self) -> UpdateDomainConfig
pub fn update_domain_config(&self) -> UpdateDomainConfig
Constructs a fluent builder for the UpdateDomainConfig operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of the domain you’re updating.
cluster_config(ClusterConfig)/set_cluster_config(Option<ClusterConfig>):The type and number of instances to instantiate for the domain cluster.
ebs_options(EbsOptions)/set_ebs_options(Option<EbsOptions>):Specify the type and size of the EBS volume to use.
snapshot_options(SnapshotOptions)/set_snapshot_options(Option<SnapshotOptions>):Option to set the time, in UTC format, for the daily automated snapshot. Default value is
0hours.vpc_options(VpcOptions)/set_vpc_options(Option<VpcOptions>):Options to specify the subnets and security groups for the VPC endpoint. For more information, see Launching your Amazon OpenSearch Service domains using a VPC .
cognito_options(CognitoOptions)/set_cognito_options(Option<CognitoOptions>):Options to specify the Cognito user and identity pools for OpenSearch Dashboards authentication. For more information, see Configuring Amazon Cognito authentication for OpenSearch Dashboards.
advanced_options(HashMap<String, String>)/set_advanced_options(Option<HashMap<String, String>>):Modifies the advanced option to allow references to indices in an HTTP request body. Must be
falsewhen configuring access to individual sub-resources. By default, the value istrue. See Advanced options for more information.access_policies(impl Into<String>)/set_access_policies(Option<String>):IAM access policy as a JSON-formatted string.
log_publishing_options(HashMap<LogType, LogPublishingOption>)/set_log_publishing_options(Option<HashMap<LogType, LogPublishingOption>>):Map of
LogTypeandLogPublishingOption, each containing options to publish a given type of OpenSearch log.encryption_at_rest_options(EncryptionAtRestOptions)/set_encryption_at_rest_options(Option<EncryptionAtRestOptions>):Specifies encryption of data at rest options.
domain_endpoint_options(DomainEndpointOptions)/set_domain_endpoint_options(Option<DomainEndpointOptions>):Options to specify configuration that will be applied to the domain endpoint.
node_to_node_encryption_options(NodeToNodeEncryptionOptions)/set_node_to_node_encryption_options(Option<NodeToNodeEncryptionOptions>):Specifies node-to-node encryption options.
advanced_security_options(AdvancedSecurityOptionsInput)/set_advanced_security_options(Option<AdvancedSecurityOptionsInput>):Specifies advanced security options.
auto_tune_options(AutoTuneOptions)/set_auto_tune_options(Option<AutoTuneOptions>):Specifies Auto-Tune options.
dry_run(bool)/set_dry_run(Option<bool>):This flag, when set to True, specifies whether the
UpdateDomainrequest should return the results of validation checks (DryRunResults) without actually applying the change.
- On success, responds with
UpdateDomainConfigOutputwith field(s):domain_config(Option<DomainConfig>):The status of the updated domain.
dry_run_results(Option<DryRunResults>):Contains result of DryRun.
- On failure, responds with
SdkError<UpdateDomainConfigError>
sourcepub fn update_package(&self) -> UpdatePackage
pub fn update_package(&self) -> UpdatePackage
Constructs a fluent builder for the UpdatePackage operation.
- The fluent builder is configurable:
package_id(impl Into<String>)/set_package_id(Option<String>):The unique identifier for the package.
package_source(PackageSource)/set_package_source(Option<PackageSource>):The Amazon S3 location for importing the package specified as
S3BucketNameandS3Keypackage_description(impl Into<String>)/set_package_description(Option<String>):A new description of the package.
commit_message(impl Into<String>)/set_commit_message(Option<String>):A commit message for the new version which is shown as part of
GetPackageVersionHistoryResponse.
- On success, responds with
UpdatePackageOutputwith field(s):package_details(Option<PackageDetails>):Information about the package.
- On failure, responds with
SdkError<UpdatePackageError>
sourcepub fn upgrade_domain(&self) -> UpgradeDomain
pub fn upgrade_domain(&self) -> UpgradeDomain
Constructs a fluent builder for the UpgradeDomain operation.
- The fluent builder is configurable:
domain_name(impl Into<String>)/set_domain_name(Option<String>):The name of an domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
target_version(impl Into<String>)/set_target_version(Option<String>):The version of OpenSearch you intend to upgrade the domain to.
perform_check_only(bool)/set_perform_check_only(Option<bool>):When true, indicates that an upgrade eligibility check needs to be performed. Does not actually perform the upgrade.
advanced_options(HashMap<String, String>)/set_advanced_options(Option<HashMap<String, String>>):Exposes select native OpenSearch configuration values from
opensearch.yml. Currently, the following advanced options are available:- Option to allow references to indices in an HTTP request body. Must be
falsewhen configuring access to individual sub-resources. By default, the value istrue. See Advanced cluster parameters for more information. - Option to specify the percentage of heap space allocated to field data. By default, this setting is unbounded.
For more information, see Advanced cluster parameters.
- Option to allow references to indices in an HTTP request body. Must be
- On success, responds with
UpgradeDomainOutputwith field(s):upgrade_id(Option<String>): (undocumented)domain_name(Option<String>):The name of an domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen).
target_version(Option<String>):The version of OpenSearch that you intend to upgrade the domain to.
perform_check_only(Option<bool>):When true, indicates that an upgrade eligibility check needs to be performed. Does not actually perform the upgrade.
advanced_options(Option<HashMap<String, String>>):Exposes select native OpenSearch configuration values from
opensearch.yml. Currently, the following advanced options are available:- Option to allow references to indices in an HTTP request body. Must be
falsewhen configuring access to individual sub-resources. By default, the value istrue. See Advanced cluster parameters for more information. - Option to specify the percentage of heap space allocated to field data. By default, this setting is unbounded.
For more information, see Advanced cluster parameters.
- Option to allow references to indices in an HTTP request body. Must be
change_progress_details(Option<ChangeProgressDetails>):Specifies change details of the domain configuration change.
- On failure, responds with
SdkError<UpgradeDomainError>
sourceimpl Client
impl Client
sourcepub fn from_conf_conn<C, E>(conf: Config, conn: C) -> Self where
C: SmithyConnector<Error = E> + Send + 'static,
E: Into<ConnectorError>,
pub fn from_conf_conn<C, E>(conf: Config, conn: C) -> Self where
C: SmithyConnector<Error = E> + Send + 'static,
E: Into<ConnectorError>,
Creates a client with the given service config and connector override.
Trait Implementations
sourceimpl From<Client<DynConnector, DynMiddleware<DynConnector>, Standard>> for Client
impl From<Client<DynConnector, DynMiddleware<DynConnector>, Standard>> for Client
sourcefn from(client: Client<DynConnector, DynMiddleware<DynConnector>>) -> Self
fn from(client: Client<DynConnector, DynMiddleware<DynConnector>>) -> Self
Performs the conversion.
Auto Trait Implementations
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more