Class ElasticsearchWatcherClient
java.lang.Object
co.elastic.clients.ApiClient<ElasticsearchTransport,ElasticsearchWatcherClient>
co.elastic.clients.elasticsearch.watcher.ElasticsearchWatcherClient
public class ElasticsearchWatcherClient extends ApiClient<ElasticsearchTransport,ElasticsearchWatcherClient>
Client for the watcher namespace.
-
Field Summary
Fields inherited from class co.elastic.clients.ApiClient
transport, transportOptions
-
Constructor Summary
Constructors Constructor Description ElasticsearchWatcherClient(ElasticsearchTransport transport)
ElasticsearchWatcherClient(ElasticsearchTransport transport, TransportOptions transportOptions)
-
Method Summary
Modifier and Type Method Description AckWatchResponse
ackWatch(AckWatchRequest request)
Acknowledges a watch, manually throttling the execution of the watch's actions.AckWatchResponse
ackWatch(java.util.function.Function<AckWatchRequest.Builder,ObjectBuilder<AckWatchRequest>> fn)
Acknowledges a watch, manually throttling the execution of the watch's actions.ActivateWatchResponse
activateWatch(ActivateWatchRequest request)
Activates a currently inactive watch.ActivateWatchResponse
activateWatch(java.util.function.Function<ActivateWatchRequest.Builder,ObjectBuilder<ActivateWatchRequest>> fn)
Activates a currently inactive watch.DeactivateWatchResponse
deactivateWatch(DeactivateWatchRequest request)
Deactivates a currently active watch.DeactivateWatchResponse
deactivateWatch(java.util.function.Function<DeactivateWatchRequest.Builder,ObjectBuilder<DeactivateWatchRequest>> fn)
Deactivates a currently active watch.DeleteWatchResponse
deleteWatch(DeleteWatchRequest request)
Removes a watch from Watcher.DeleteWatchResponse
deleteWatch(java.util.function.Function<DeleteWatchRequest.Builder,ObjectBuilder<DeleteWatchRequest>> fn)
Removes a watch from Watcher.ExecuteWatchResponse
executeWatch()
Forces the execution of a stored watch.ExecuteWatchResponse
executeWatch(ExecuteWatchRequest request)
Forces the execution of a stored watch.ExecuteWatchResponse
executeWatch(java.util.function.Function<ExecuteWatchRequest.Builder,ObjectBuilder<ExecuteWatchRequest>> fn)
Forces the execution of a stored watch.GetWatchResponse
getWatch(GetWatchRequest request)
Retrieves a watch by its ID.GetWatchResponse
getWatch(java.util.function.Function<GetWatchRequest.Builder,ObjectBuilder<GetWatchRequest>> fn)
Retrieves a watch by its ID.PutWatchResponse
putWatch(PutWatchRequest request)
Creates a new watch, or updates an existing one.PutWatchResponse
putWatch(java.util.function.Function<PutWatchRequest.Builder,ObjectBuilder<PutWatchRequest>> fn)
Creates a new watch, or updates an existing one.QueryWatchesResponse
queryWatches()
Retrieves stored watches.QueryWatchesResponse
queryWatches(QueryWatchesRequest request)
Retrieves stored watches.QueryWatchesResponse
queryWatches(java.util.function.Function<QueryWatchesRequest.Builder,ObjectBuilder<QueryWatchesRequest>> fn)
Retrieves stored watches.StartWatcherResponse
start()
Starts Watcher if it is not already running.WatcherStatsResponse
stats()
Retrieves the current Watcher metrics.WatcherStatsResponse
stats(WatcherStatsRequest request)
Retrieves the current Watcher metrics.WatcherStatsResponse
stats(java.util.function.Function<WatcherStatsRequest.Builder,ObjectBuilder<WatcherStatsRequest>> fn)
Retrieves the current Watcher metrics.StopWatcherResponse
stop()
Stops Watcher if it is running.ElasticsearchWatcherClient
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
-
ElasticsearchWatcherClient
-
ElasticsearchWatcherClient
public ElasticsearchWatcherClient(ElasticsearchTransport transport, @Nullable TransportOptions transportOptions)
-
-
Method Details
-
withTransportOptions
public ElasticsearchWatcherClient withTransportOptions(@Nullable TransportOptions transportOptions)Description copied from class:ApiClient
Creates a new client with some request options- Specified by:
withTransportOptions
in classApiClient<ElasticsearchTransport,ElasticsearchWatcherClient>
-
ackWatch
public AckWatchResponse ackWatch(AckWatchRequest request) throws java.io.IOException, ElasticsearchExceptionAcknowledges 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 AckWatchResponse ackWatch(java.util.function.Function<AckWatchRequest.Builder,ObjectBuilder<AckWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionAcknowledges a watch, manually throttling the execution of the watch's actions.- Parameters:
fn
- a function that initializes a builder to create theAckWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
activateWatch
public ActivateWatchResponse activateWatch(ActivateWatchRequest request) throws java.io.IOException, ElasticsearchExceptionActivates a currently inactive watch.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
activateWatch
public final ActivateWatchResponse activateWatch(java.util.function.Function<ActivateWatchRequest.Builder,ObjectBuilder<ActivateWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionActivates a currently inactive watch.- Parameters:
fn
- a function that initializes a builder to create theActivateWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
deactivateWatch
public DeactivateWatchResponse deactivateWatch(DeactivateWatchRequest request) throws java.io.IOException, ElasticsearchExceptionDeactivates a currently active watch.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
deactivateWatch
public final DeactivateWatchResponse deactivateWatch(java.util.function.Function<DeactivateWatchRequest.Builder,ObjectBuilder<DeactivateWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionDeactivates a currently active watch.- Parameters:
fn
- a function that initializes a builder to create theDeactivateWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
deleteWatch
public DeleteWatchResponse deleteWatch(DeleteWatchRequest request) throws java.io.IOException, ElasticsearchExceptionRemoves a watch from Watcher.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
deleteWatch
public final DeleteWatchResponse deleteWatch(java.util.function.Function<DeleteWatchRequest.Builder,ObjectBuilder<DeleteWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRemoves a watch from Watcher.- Parameters:
fn
- a function that initializes a builder to create theDeleteWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
executeWatch
public ExecuteWatchResponse executeWatch(ExecuteWatchRequest request) throws java.io.IOException, ElasticsearchExceptionForces the execution of a stored watch.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
executeWatch
public final ExecuteWatchResponse executeWatch(java.util.function.Function<ExecuteWatchRequest.Builder,ObjectBuilder<ExecuteWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionForces the execution of a stored watch.- Parameters:
fn
- a function that initializes a builder to create theExecuteWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
executeWatch
Forces the execution of a stored watch.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
getWatch
public GetWatchResponse getWatch(GetWatchRequest request) throws java.io.IOException, ElasticsearchExceptionRetrieves a watch by its ID.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
getWatch
public final GetWatchResponse getWatch(java.util.function.Function<GetWatchRequest.Builder,ObjectBuilder<GetWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRetrieves a watch by its ID.- Parameters:
fn
- a function that initializes a builder to create theGetWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
putWatch
public PutWatchResponse putWatch(PutWatchRequest request) throws java.io.IOException, ElasticsearchExceptionCreates a new watch, or updates an existing one.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
putWatch
public final PutWatchResponse putWatch(java.util.function.Function<PutWatchRequest.Builder,ObjectBuilder<PutWatchRequest>> fn) throws java.io.IOException, ElasticsearchExceptionCreates a new watch, or updates an existing one.- Parameters:
fn
- a function that initializes a builder to create thePutWatchRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
queryWatches
public QueryWatchesResponse queryWatches(QueryWatchesRequest request) throws java.io.IOException, ElasticsearchExceptionRetrieves stored watches.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
queryWatches
public final QueryWatchesResponse queryWatches(java.util.function.Function<QueryWatchesRequest.Builder,ObjectBuilder<QueryWatchesRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRetrieves stored watches.- Parameters:
fn
- a function that initializes a builder to create theQueryWatchesRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
queryWatches
Retrieves stored watches.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
start
Starts Watcher if it is not already running.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
stats
public WatcherStatsResponse stats(WatcherStatsRequest request) throws java.io.IOException, ElasticsearchExceptionRetrieves the current Watcher metrics.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
stats
public final WatcherStatsResponse stats(java.util.function.Function<WatcherStatsRequest.Builder,ObjectBuilder<WatcherStatsRequest>> fn) throws java.io.IOException, ElasticsearchExceptionRetrieves the current Watcher metrics.- Parameters:
fn
- a function that initializes a builder to create theWatcherStatsRequest
- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
stats
Retrieves the current Watcher metrics.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-
stop
Stops Watcher if it is running.- Throws:
java.io.IOException
ElasticsearchException
- See Also:
- Documentation on elastic.co
-