Class ElasticsearchCcrAsyncClient
java.lang.Object
co.elastic.clients.ApiClient<ElasticsearchTransport,ElasticsearchCcrAsyncClient>
co.elastic.clients.elasticsearch.ccr.ElasticsearchCcrAsyncClient
public class ElasticsearchCcrAsyncClient extends ApiClient<ElasticsearchTransport,ElasticsearchCcrAsyncClient>
Client for the ccr namespace.
-
Field Summary
Fields inherited from class co.elastic.clients.ApiClient
transport, transportOptions
-
Constructor Summary
Constructors Constructor Description ElasticsearchCcrAsyncClient(ElasticsearchTransport transport)
ElasticsearchCcrAsyncClient(ElasticsearchTransport transport, TransportOptions transportOptions)
-
Method Summary
Modifier and Type Method Description java.util.concurrent.CompletableFuture<DeleteAutoFollowPatternResponse>
deleteAutoFollowPattern(DeleteAutoFollowPatternRequest request)
Deletes auto-follow patterns.java.util.concurrent.CompletableFuture<DeleteAutoFollowPatternResponse>
deleteAutoFollowPattern(java.util.function.Function<DeleteAutoFollowPatternRequest.Builder,ObjectBuilder<DeleteAutoFollowPatternRequest>> fn)
Deletes auto-follow patterns.java.util.concurrent.CompletableFuture<FollowResponse>
follow(FollowRequest request)
Creates a new follower index configured to follow the referenced leader index.java.util.concurrent.CompletableFuture<FollowResponse>
follow(java.util.function.Function<FollowRequest.Builder,ObjectBuilder<FollowRequest>> fn)
Creates a new follower index configured to follow the referenced leader index.java.util.concurrent.CompletableFuture<FollowInfoResponse>
followInfo(FollowInfoRequest request)
Retrieves information about all follower indices, including parameters and status for each follower indexjava.util.concurrent.CompletableFuture<FollowInfoResponse>
followInfo(java.util.function.Function<FollowInfoRequest.Builder,ObjectBuilder<FollowInfoRequest>> fn)
Retrieves information about all follower indices, including parameters and status for each follower indexjava.util.concurrent.CompletableFuture<FollowStatsResponse>
followStats(FollowStatsRequest request)
Retrieves follower stats.java.util.concurrent.CompletableFuture<FollowStatsResponse>
followStats(java.util.function.Function<FollowStatsRequest.Builder,ObjectBuilder<FollowStatsRequest>> fn)
Retrieves follower stats.java.util.concurrent.CompletableFuture<ForgetFollowerResponse>
forgetFollower(ForgetFollowerRequest request)
Removes the follower retention leases from the leader.java.util.concurrent.CompletableFuture<ForgetFollowerResponse>
forgetFollower(java.util.function.Function<ForgetFollowerRequest.Builder,ObjectBuilder<ForgetFollowerRequest>> fn)
Removes the follower retention leases from the leader.java.util.concurrent.CompletableFuture<GetAutoFollowPatternResponse>
getAutoFollowPattern()
Gets configured auto-follow patterns.java.util.concurrent.CompletableFuture<GetAutoFollowPatternResponse>
getAutoFollowPattern(GetAutoFollowPatternRequest request)
Gets configured auto-follow patterns.java.util.concurrent.CompletableFuture<GetAutoFollowPatternResponse>
getAutoFollowPattern(java.util.function.Function<GetAutoFollowPatternRequest.Builder,ObjectBuilder<GetAutoFollowPatternRequest>> fn)
Gets configured auto-follow patterns.java.util.concurrent.CompletableFuture<PauseAutoFollowPatternResponse>
pauseAutoFollowPattern(PauseAutoFollowPatternRequest request)
Pauses an auto-follow patternjava.util.concurrent.CompletableFuture<PauseAutoFollowPatternResponse>
pauseAutoFollowPattern(java.util.function.Function<PauseAutoFollowPatternRequest.Builder,ObjectBuilder<PauseAutoFollowPatternRequest>> fn)
Pauses an auto-follow patternjava.util.concurrent.CompletableFuture<PauseFollowResponse>
pauseFollow(PauseFollowRequest request)
Pauses a follower index.java.util.concurrent.CompletableFuture<PauseFollowResponse>
pauseFollow(java.util.function.Function<PauseFollowRequest.Builder,ObjectBuilder<PauseFollowRequest>> fn)
Pauses a follower index.java.util.concurrent.CompletableFuture<PutAutoFollowPatternResponse>
putAutoFollowPattern(PutAutoFollowPatternRequest request)
Creates a new named collection of auto-follow patterns against a specified remote cluster.java.util.concurrent.CompletableFuture<PutAutoFollowPatternResponse>
putAutoFollowPattern(java.util.function.Function<PutAutoFollowPatternRequest.Builder,ObjectBuilder<PutAutoFollowPatternRequest>> fn)
Creates a new named collection of auto-follow patterns against a specified remote cluster.java.util.concurrent.CompletableFuture<ResumeAutoFollowPatternResponse>
resumeAutoFollowPattern(ResumeAutoFollowPatternRequest request)
Resumes an auto-follow pattern that has been pausedjava.util.concurrent.CompletableFuture<ResumeAutoFollowPatternResponse>
resumeAutoFollowPattern(java.util.function.Function<ResumeAutoFollowPatternRequest.Builder,ObjectBuilder<ResumeAutoFollowPatternRequest>> fn)
Resumes an auto-follow pattern that has been pausedjava.util.concurrent.CompletableFuture<ResumeFollowResponse>
resumeFollow(ResumeFollowRequest request)
Resumes a follower index that has been pausedjava.util.concurrent.CompletableFuture<ResumeFollowResponse>
resumeFollow(java.util.function.Function<ResumeFollowRequest.Builder,ObjectBuilder<ResumeFollowRequest>> fn)
Resumes a follower index that has been pausedjava.util.concurrent.CompletableFuture<CcrStatsResponse>
stats()
Gets all stats related to cross-cluster replication.java.util.concurrent.CompletableFuture<UnfollowResponse>
unfollow(UnfollowRequest request)
Stops the following task associated with a follower index and removes index metadata and settings associated with cross-cluster replication.java.util.concurrent.CompletableFuture<UnfollowResponse>
unfollow(java.util.function.Function<UnfollowRequest.Builder,ObjectBuilder<UnfollowRequest>> fn)
Stops the following task associated with a follower index and removes index metadata and settings associated with cross-cluster replication.ElasticsearchCcrAsyncClient
withTransportOptions(TransportOptions transportOptions)
Creates a new client with some request optionsMethods inherited from class co.elastic.clients.ApiClient
_transport, _transportOptions, getDeserializer
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
ElasticsearchCcrAsyncClient
-
ElasticsearchCcrAsyncClient
public ElasticsearchCcrAsyncClient(ElasticsearchTransport transport, @Nullable TransportOptions transportOptions)
-
-
Method Details
-
withTransportOptions
public ElasticsearchCcrAsyncClient withTransportOptions(@Nullable TransportOptions transportOptions)Description copied from class:ApiClient
Creates a new client with some request options- Specified by:
withTransportOptions
in classApiClient<ElasticsearchTransport,ElasticsearchCcrAsyncClient>
-
deleteAutoFollowPattern
public java.util.concurrent.CompletableFuture<DeleteAutoFollowPatternResponse> deleteAutoFollowPattern(DeleteAutoFollowPatternRequest request) throws java.io.IOException, ElasticsearchExceptionDeletes auto-follow patterns.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
deleteAutoFollowPattern
public final java.util.concurrent.CompletableFuture<DeleteAutoFollowPatternResponse> deleteAutoFollowPattern(java.util.function.Function<DeleteAutoFollowPatternRequest.Builder,ObjectBuilder<DeleteAutoFollowPatternRequest>> fn) throws java.io.IOException, ElasticsearchExceptionDeletes auto-follow patterns.- Parameters:
fn
- a function that initializes a builder to create theDeleteAutoFollowPatternRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
follow
public java.util.concurrent.CompletableFuture<FollowResponse> follow(FollowRequest request) throws java.io.IOException, ElasticsearchExceptionCreates a new follower index configured to follow the referenced leader index.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
follow
public final java.util.concurrent.CompletableFuture<FollowResponse> follow(java.util.function.Function<FollowRequest.Builder,ObjectBuilder<FollowRequest>> fn) throws java.io.IOException, ElasticsearchExceptionCreates a new follower index configured to follow the referenced leader index.- Parameters:
fn
- a function that initializes a builder to create theFollowRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
followInfo
public java.util.concurrent.CompletableFuture<FollowInfoResponse> followInfo(FollowInfoRequest request) throws java.io.IOException, ElasticsearchExceptionRetrieves information about all follower indices, including parameters and status for each follower index- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
followInfo
public final java.util.concurrent.CompletableFuture<FollowInfoResponse> followInfo(java.util.function.Function<FollowInfoRequest.Builder,ObjectBuilder<FollowInfoRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRetrieves information about all follower indices, including parameters and status for each follower index- Parameters:
fn
- a function that initializes a builder to create theFollowInfoRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
followStats
public java.util.concurrent.CompletableFuture<FollowStatsResponse> followStats(FollowStatsRequest request) throws java.io.IOException, ElasticsearchExceptionRetrieves follower stats. return shard-level stats about the following tasks associated with each shard for the specified indices.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
followStats
public final java.util.concurrent.CompletableFuture<FollowStatsResponse> followStats(java.util.function.Function<FollowStatsRequest.Builder,ObjectBuilder<FollowStatsRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRetrieves follower stats. return shard-level stats about the following tasks associated with each shard for the specified indices.- Parameters:
fn
- a function that initializes a builder to create theFollowStatsRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
forgetFollower
public java.util.concurrent.CompletableFuture<ForgetFollowerResponse> forgetFollower(ForgetFollowerRequest request) throws java.io.IOException, ElasticsearchExceptionRemoves the follower retention leases from the leader.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
forgetFollower
public final java.util.concurrent.CompletableFuture<ForgetFollowerResponse> forgetFollower(java.util.function.Function<ForgetFollowerRequest.Builder,ObjectBuilder<ForgetFollowerRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRemoves the follower retention leases from the leader.- Parameters:
fn
- a function that initializes a builder to create theForgetFollowerRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
getAutoFollowPattern
public java.util.concurrent.CompletableFuture<GetAutoFollowPatternResponse> getAutoFollowPattern(GetAutoFollowPatternRequest request) throws java.io.IOException, ElasticsearchExceptionGets configured auto-follow patterns. Returns the specified auto-follow pattern collection.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
getAutoFollowPattern
public final java.util.concurrent.CompletableFuture<GetAutoFollowPatternResponse> getAutoFollowPattern(java.util.function.Function<GetAutoFollowPatternRequest.Builder,ObjectBuilder<GetAutoFollowPatternRequest>> fn) throws java.io.IOException, ElasticsearchExceptionGets configured auto-follow patterns. Returns the specified auto-follow pattern collection.- Parameters:
fn
- a function that initializes a builder to create theGetAutoFollowPatternRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
getAutoFollowPattern
public java.util.concurrent.CompletableFuture<GetAutoFollowPatternResponse> getAutoFollowPattern() throws java.io.IOException, ElasticsearchExceptionGets configured auto-follow patterns. Returns the specified auto-follow pattern collection.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
pauseAutoFollowPattern
public java.util.concurrent.CompletableFuture<PauseAutoFollowPatternResponse> pauseAutoFollowPattern(PauseAutoFollowPatternRequest request) throws java.io.IOException, ElasticsearchExceptionPauses an auto-follow pattern- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
pauseAutoFollowPattern
public final java.util.concurrent.CompletableFuture<PauseAutoFollowPatternResponse> pauseAutoFollowPattern(java.util.function.Function<PauseAutoFollowPatternRequest.Builder,ObjectBuilder<PauseAutoFollowPatternRequest>> fn) throws java.io.IOException, ElasticsearchExceptionPauses an auto-follow pattern- Parameters:
fn
- a function that initializes a builder to create thePauseAutoFollowPatternRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
pauseFollow
public java.util.concurrent.CompletableFuture<PauseFollowResponse> pauseFollow(PauseFollowRequest request) throws java.io.IOException, ElasticsearchExceptionPauses a follower index. The follower index will not fetch any additional operations from the leader index.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
pauseFollow
public final java.util.concurrent.CompletableFuture<PauseFollowResponse> pauseFollow(java.util.function.Function<PauseFollowRequest.Builder,ObjectBuilder<PauseFollowRequest>> fn) throws java.io.IOException, ElasticsearchExceptionPauses a follower index. The follower index will not fetch any additional operations from the leader index.- Parameters:
fn
- a function that initializes a builder to create thePauseFollowRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
putAutoFollowPattern
public java.util.concurrent.CompletableFuture<PutAutoFollowPatternResponse> putAutoFollowPattern(PutAutoFollowPatternRequest request) throws java.io.IOException, ElasticsearchExceptionCreates a new named collection of auto-follow patterns against a specified remote cluster. Newly created indices on the remote cluster matching any of the specified patterns will be automatically configured as follower indices.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
putAutoFollowPattern
public final java.util.concurrent.CompletableFuture<PutAutoFollowPatternResponse> putAutoFollowPattern(java.util.function.Function<PutAutoFollowPatternRequest.Builder,ObjectBuilder<PutAutoFollowPatternRequest>> fn) throws java.io.IOException, ElasticsearchExceptionCreates a new named collection of auto-follow patterns against a specified remote cluster. Newly created indices on the remote cluster matching any of the specified patterns will be automatically configured as follower indices.- Parameters:
fn
- a function that initializes a builder to create thePutAutoFollowPatternRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
resumeAutoFollowPattern
public java.util.concurrent.CompletableFuture<ResumeAutoFollowPatternResponse> resumeAutoFollowPattern(ResumeAutoFollowPatternRequest request) throws java.io.IOException, ElasticsearchExceptionResumes an auto-follow pattern that has been paused- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
resumeAutoFollowPattern
public final java.util.concurrent.CompletableFuture<ResumeAutoFollowPatternResponse> resumeAutoFollowPattern(java.util.function.Function<ResumeAutoFollowPatternRequest.Builder,ObjectBuilder<ResumeAutoFollowPatternRequest>> fn) throws java.io.IOException, ElasticsearchExceptionResumes an auto-follow pattern that has been paused- Parameters:
fn
- a function that initializes a builder to create theResumeAutoFollowPatternRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
resumeFollow
public java.util.concurrent.CompletableFuture<ResumeFollowResponse> resumeFollow(ResumeFollowRequest request) throws java.io.IOException, ElasticsearchExceptionResumes a follower index that has been paused- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
resumeFollow
public final java.util.concurrent.CompletableFuture<ResumeFollowResponse> resumeFollow(java.util.function.Function<ResumeFollowRequest.Builder,ObjectBuilder<ResumeFollowRequest>> fn) throws java.io.IOException, ElasticsearchExceptionResumes a follower index that has been paused- Parameters:
fn
- a function that initializes a builder to create theResumeFollowRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
stats
public java.util.concurrent.CompletableFuture<CcrStatsResponse> stats() throws java.io.IOException, ElasticsearchExceptionGets all stats related to cross-cluster replication.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
unfollow
public java.util.concurrent.CompletableFuture<UnfollowResponse> unfollow(UnfollowRequest request) throws java.io.IOException, ElasticsearchExceptionStops the following task associated with a follower index and removes index metadata and settings associated with cross-cluster replication.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
unfollow
public final java.util.concurrent.CompletableFuture<UnfollowResponse> unfollow(java.util.function.Function<UnfollowRequest.Builder,ObjectBuilder<UnfollowRequest>> fn) throws java.io.IOException, ElasticsearchExceptionStops the following task associated with a follower index and removes index metadata and settings associated with cross-cluster replication.- Parameters:
fn
- a function that initializes a builder to create theUnfollowRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-