Package co.elastic.clients.elasticsearch.watcher

Class ElasticsearchWatcherAsyncClient

java.lang.Object

co.elastic.clients.ApiClient<ElasticsearchTransport,ElasticsearchWatcherAsyncClient>

co.elastic.clients.elasticsearch.watcher.ElasticsearchWatcherAsyncClient

public class ElasticsearchWatcherAsyncClient
extends ApiClient<ElasticsearchTransport,ElasticsearchWatcherAsyncClient>

Client for the watcher namespace.

Field Summary

Fields inherited from class co.elastic.clients.ApiClient

transport, transportOptions

Constructor Summary

Constructors

Constructor	Description
ElasticsearchWatcherAsyncClient(ElasticsearchTransport transport)
ElasticsearchWatcherAsyncClient(ElasticsearchTransport transport, TransportOptions transportOptions)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<AckWatchResponse>	ackWatch(AckWatchRequest request)	Acknowledges a watch, manually throttling the execution of the watch's actions.
java.util.concurrent.CompletableFuture<AckWatchResponse>	ackWatch(java.util.function.Function<AckWatchRequest.Builder,ObjectBuilder<AckWatchRequest>> fn)	Acknowledges a watch, manually throttling the execution of the watch's actions.
java.util.concurrent.CompletableFuture<ActivateWatchResponse>	activateWatch(ActivateWatchRequest request)	Activates a currently inactive watch.
java.util.concurrent.CompletableFuture<ActivateWatchResponse>	activateWatch(java.util.function.Function<ActivateWatchRequest.Builder,ObjectBuilder<ActivateWatchRequest>> fn)	Activates a currently inactive watch.
java.util.concurrent.CompletableFuture<DeactivateWatchResponse>	deactivateWatch(DeactivateWatchRequest request)	Deactivates a currently active watch.
java.util.concurrent.CompletableFuture<DeactivateWatchResponse>	deactivateWatch(java.util.function.Function<DeactivateWatchRequest.Builder,ObjectBuilder<DeactivateWatchRequest>> fn)	Deactivates a currently active watch.
java.util.concurrent.CompletableFuture<DeleteWatchResponse>	deleteWatch(DeleteWatchRequest request)	Removes a watch from Watcher.
java.util.concurrent.CompletableFuture<DeleteWatchResponse>	deleteWatch(java.util.function.Function<DeleteWatchRequest.Builder,ObjectBuilder<DeleteWatchRequest>> fn)	Removes a watch from Watcher.
java.util.concurrent.CompletableFuture<ExecuteWatchResponse>	executeWatch()	Forces the execution of a stored watch.
java.util.concurrent.CompletableFuture<ExecuteWatchResponse>	executeWatch(ExecuteWatchRequest request)	Forces the execution of a stored watch.
java.util.concurrent.CompletableFuture<ExecuteWatchResponse>	executeWatch(java.util.function.Function<ExecuteWatchRequest.Builder,ObjectBuilder<ExecuteWatchRequest>> fn)	Forces the execution of a stored watch.
java.util.concurrent.CompletableFuture<GetWatchResponse>	getWatch(GetWatchRequest request)	Retrieves a watch by its ID.
java.util.concurrent.CompletableFuture<GetWatchResponse>	getWatch(java.util.function.Function<GetWatchRequest.Builder,ObjectBuilder<GetWatchRequest>> fn)	Retrieves a watch by its ID.
java.util.concurrent.CompletableFuture<PutWatchResponse>	putWatch(PutWatchRequest request)	Creates a new watch, or updates an existing one.
java.util.concurrent.CompletableFuture<PutWatchResponse>	putWatch(java.util.function.Function<PutWatchRequest.Builder,ObjectBuilder<PutWatchRequest>> fn)	Creates a new watch, or updates an existing one.
java.util.concurrent.CompletableFuture<QueryWatchesResponse>	queryWatches()	Retrieves stored watches.
java.util.concurrent.CompletableFuture<QueryWatchesResponse>	queryWatches(QueryWatchesRequest request)	Retrieves stored watches.
java.util.concurrent.CompletableFuture<QueryWatchesResponse>	queryWatches(java.util.function.Function<QueryWatchesRequest.Builder,ObjectBuilder<QueryWatchesRequest>> fn)	Retrieves stored watches.
java.util.concurrent.CompletableFuture<StartWatcherResponse>	start()	Starts Watcher if it is not already running.
java.util.concurrent.CompletableFuture<WatcherStatsResponse>	stats()	Retrieves the current Watcher metrics.
java.util.concurrent.CompletableFuture<WatcherStatsResponse>	stats(WatcherStatsRequest request)	Retrieves the current Watcher metrics.
java.util.concurrent.CompletableFuture<WatcherStatsResponse>	stats(java.util.function.Function<WatcherStatsRequest.Builder,ObjectBuilder<WatcherStatsRequest>> fn)	Retrieves the current Watcher metrics.
java.util.concurrent.CompletableFuture<StopWatcherResponse>	stop()	Stops Watcher if it is running.
ElasticsearchWatcherAsyncClient	withTransportOptions(TransportOptions transportOptions)	Creates a new client with some request options

Methods 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

ElasticsearchWatcherAsyncClient

public ElasticsearchWatcherAsyncClient(ElasticsearchTransport transport)

ElasticsearchWatcherAsyncClient

public ElasticsearchWatcherAsyncClient(ElasticsearchTransport transport,
@Nullable
TransportOptions transportOptions)

Method Details

withTransportOptions

public ElasticsearchWatcherAsyncClient withTransportOptions(@Nullable
TransportOptions transportOptions)

Description copied from class: ApiClient

Creates a new client with some request options

Specified by:

withTransportOptions in class ApiClient<ElasticsearchTransport,ElasticsearchWatcherAsyncClient>

ackWatch

public java.util.concurrent.CompletableFuture<AckWatchResponse> ackWatch(AckWatchRequest request)
                                                                  throws java.io.IOException,
ElasticsearchException

Acknowledges a watch, manually throttling the execution of the watch's actions.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

ackWatch

public final java.util.concurrent.CompletableFuture<AckWatchResponse> ackWatch(java.util.function.Function<AckWatchRequest.Builder,ObjectBuilder<AckWatchRequest>> fn)
                                                                        throws java.io.IOException,
ElasticsearchException

Acknowledges a watch, manually throttling the execution of the watch's actions.

Parameters:

fn - a function that initializes a builder to create the AckWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

activateWatch

public java.util.concurrent.CompletableFuture<ActivateWatchResponse> activateWatch(ActivateWatchRequest request)
                                                                            throws java.io.IOException,
ElasticsearchException

Activates a currently inactive watch.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

activateWatch

public final java.util.concurrent.CompletableFuture<ActivateWatchResponse> activateWatch(java.util.function.Function<ActivateWatchRequest.Builder,ObjectBuilder<ActivateWatchRequest>> fn)
                                                                                  throws java.io.IOException,
ElasticsearchException

Activates a currently inactive watch.

Parameters:

fn - a function that initializes a builder to create the ActivateWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

deactivateWatch

public java.util.concurrent.CompletableFuture<DeactivateWatchResponse> deactivateWatch(DeactivateWatchRequest request)
                                                                                throws java.io.IOException,
ElasticsearchException

Deactivates a currently active watch.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

deactivateWatch

public final java.util.concurrent.CompletableFuture<DeactivateWatchResponse> deactivateWatch(java.util.function.Function<DeactivateWatchRequest.Builder,ObjectBuilder<DeactivateWatchRequest>> fn)
                                                                                      throws java.io.IOException,
ElasticsearchException

Deactivates a currently active watch.

Parameters:

fn - a function that initializes a builder to create the DeactivateWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

deleteWatch

public java.util.concurrent.CompletableFuture<DeleteWatchResponse> deleteWatch(DeleteWatchRequest request)
                                                                        throws java.io.IOException,
ElasticsearchException

Removes a watch from Watcher.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

deleteWatch

public final java.util.concurrent.CompletableFuture<DeleteWatchResponse> deleteWatch(java.util.function.Function<DeleteWatchRequest.Builder,ObjectBuilder<DeleteWatchRequest>> fn)
                                                                              throws java.io.IOException,
ElasticsearchException

Removes a watch from Watcher.

Parameters:

fn - a function that initializes a builder to create the DeleteWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

executeWatch

public java.util.concurrent.CompletableFuture<ExecuteWatchResponse> executeWatch(ExecuteWatchRequest request)
                                                                          throws java.io.IOException,
ElasticsearchException

Forces the execution of a stored watch.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

executeWatch

public final java.util.concurrent.CompletableFuture<ExecuteWatchResponse> executeWatch(java.util.function.Function<ExecuteWatchRequest.Builder,ObjectBuilder<ExecuteWatchRequest>> fn)
                                                                                throws java.io.IOException,
ElasticsearchException

Forces the execution of a stored watch.

Parameters:

fn - a function that initializes a builder to create the ExecuteWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

executeWatch

public java.util.concurrent.CompletableFuture<ExecuteWatchResponse> executeWatch()
                                                                          throws java.io.IOException,
ElasticsearchException

Forces the execution of a stored watch.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getWatch

public java.util.concurrent.CompletableFuture<GetWatchResponse> getWatch(GetWatchRequest request)
                                                                  throws java.io.IOException,
ElasticsearchException

Retrieves a watch by its ID.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getWatch

public final java.util.concurrent.CompletableFuture<GetWatchResponse> getWatch(java.util.function.Function<GetWatchRequest.Builder,ObjectBuilder<GetWatchRequest>> fn)
                                                                        throws java.io.IOException,
ElasticsearchException

Retrieves a watch by its ID.

Parameters:

fn - a function that initializes a builder to create the GetWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

putWatch

public java.util.concurrent.CompletableFuture<PutWatchResponse> putWatch(PutWatchRequest request)
                                                                  throws java.io.IOException,
ElasticsearchException

Creates a new watch, or updates an existing one.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

putWatch

public final java.util.concurrent.CompletableFuture<PutWatchResponse> putWatch(java.util.function.Function<PutWatchRequest.Builder,ObjectBuilder<PutWatchRequest>> fn)
                                                                        throws java.io.IOException,
ElasticsearchException

Creates a new watch, or updates an existing one.

Parameters:

fn - a function that initializes a builder to create the PutWatchRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

queryWatches

public java.util.concurrent.CompletableFuture<QueryWatchesResponse> queryWatches(QueryWatchesRequest request)
                                                                          throws java.io.IOException,
ElasticsearchException

Retrieves stored watches.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

queryWatches

public final java.util.concurrent.CompletableFuture<QueryWatchesResponse> queryWatches(java.util.function.Function<QueryWatchesRequest.Builder,ObjectBuilder<QueryWatchesRequest>> fn)
                                                                                throws java.io.IOException,
ElasticsearchException

Retrieves stored watches.

Parameters:

fn - a function that initializes a builder to create the QueryWatchesRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

queryWatches

public java.util.concurrent.CompletableFuture<QueryWatchesResponse> queryWatches()
                                                                          throws java.io.IOException,
ElasticsearchException

Retrieves stored watches.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

start

public java.util.concurrent.CompletableFuture<StartWatcherResponse> start()
                                                                   throws java.io.IOException,
ElasticsearchException

Starts Watcher if it is not already running.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

stats

public java.util.concurrent.CompletableFuture<WatcherStatsResponse> stats(WatcherStatsRequest request)
                                                                   throws java.io.IOException,
ElasticsearchException

Retrieves the current Watcher metrics.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

stats

public final java.util.concurrent.CompletableFuture<WatcherStatsResponse> stats(java.util.function.Function<WatcherStatsRequest.Builder,ObjectBuilder<WatcherStatsRequest>> fn)
                                                                         throws java.io.IOException,
ElasticsearchException

Retrieves the current Watcher metrics.

Parameters:

fn - a function that initializes a builder to create the WatcherStatsRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

stats

public java.util.concurrent.CompletableFuture<WatcherStatsResponse> stats()
                                                                   throws java.io.IOException,
ElasticsearchException

Retrieves the current Watcher metrics.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

stop

public java.util.concurrent.CompletableFuture<StopWatcherResponse> stop()
                                                                 throws java.io.IOException,
ElasticsearchException

Stops Watcher if it is running.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co