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
Converts to this type from the input type.
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> 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