Package org.elasticsearch.client

Class WatcherClient

java.lang.Object
org.elasticsearch.client.WatcherClient
public final class WatcherClient
extends java.lang.Object

  • Method Details

    • startWatchService

      public org.elasticsearch.action.support.master.AcknowledgedResponse startWatchService​(StartWatchServiceRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Start the watch service See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • startWatchServiceAsync

      public org.elasticsearch.client.Cancellable startWatchServiceAsync​(StartWatchServiceRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.support.master.AcknowledgedResponse> listener)
      Asynchronously start the watch service See the docs for more.
      Parameters:
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      cancellable that may be used to cancel the request

    • stopWatchService

      public org.elasticsearch.action.support.master.AcknowledgedResponse stopWatchService​(StopWatchServiceRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Stop the watch service See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • stopWatchServiceAsync

      public org.elasticsearch.client.Cancellable stopWatchServiceAsync​(StopWatchServiceRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.support.master.AcknowledgedResponse> listener)
      Asynchronously stop the watch service See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      cancellable that may be used to cancel the request

    • putWatch

      public PutWatchResponse putWatch​(PutWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Put a watch into the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • putWatchAsync

      public org.elasticsearch.client.Cancellable putWatchAsync​(PutWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<PutWatchResponse> listener)
      Asynchronously put a watch into the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon request completion
      Returns:
      cancellable that may be used to cancel the request

    • getWatch

      public GetWatchResponse getWatch​(GetWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Gets a watch from the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • getWatchAsync

      public org.elasticsearch.client.Cancellable getWatchAsync​(GetWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<GetWatchResponse> listener)
      Asynchronously gets a watch into the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon request completion
      Returns:
      cancellable that may be used to cancel the request

    • deactivateWatch

      public DeactivateWatchResponse deactivateWatch​(DeactivateWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Deactivate an existing watch See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • deactivateWatchAsync

      public org.elasticsearch.client.Cancellable deactivateWatchAsync​(DeactivateWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<DeactivateWatchResponse> listener)
      Asynchronously deactivate an existing watch See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon request completion
      Returns:
      cancellable that may be used to cancel the request

    • deleteWatch

      public DeleteWatchResponse deleteWatch​(DeleteWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Deletes a watch from the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • deleteWatchAsync

      public org.elasticsearch.client.Cancellable deleteWatchAsync​(DeleteWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<DeleteWatchResponse> listener)
      Asynchronously deletes a watch from the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon request completion
      Returns:
      cancellable that may be used to cancel the request

    • ackWatch

      public AckWatchResponse ackWatch​(AckWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Acknowledges a watch. See the docs for more information.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - if there is a problem sending the request or parsing back the response

    • ackWatchAsync

      public org.elasticsearch.client.Cancellable ackWatchAsync​(AckWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<AckWatchResponse> listener)
      Asynchronously acknowledges a watch. See the docs for more information.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon completion of the request
      Returns:
      cancellable that may be used to cancel the request

    • activateWatch

      public ActivateWatchResponse activateWatch​(ActivateWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Activate a watch from the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • activateWatchAsync

      public org.elasticsearch.client.Cancellable activateWatchAsync​(ActivateWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<ActivateWatchResponse> listener)
      Asynchronously activates a watch from the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon request completion
      Returns:
      cancellable that may be used to cancel the request

    • executeWatch

      public ExecuteWatchResponse executeWatch​(ExecuteWatchRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Execute a watch on the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - if there is a problem sending the request or parsing the response

    • executeWatchAsync

      public org.elasticsearch.client.Cancellable executeWatchAsync​(ExecuteWatchRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<ExecuteWatchResponse> listener)
      Asynchronously execute a watch on the cluster See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notifed upon request completion
      Returns:
      cancellable that may be used to cancel the request

    • watcherStats

      public WatcherStatsResponse watcherStats​(WatcherStatsRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOException
      Get the watcher stats See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      Returns:
      the response
      Throws:
      java.io.IOException - in case there is a problem sending the request or parsing back the response

    • watcherStatsAsync

      public org.elasticsearch.client.Cancellable watcherStatsAsync​(WatcherStatsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<WatcherStatsResponse> listener)
      Asynchronously get the watcher stats See the docs for more.
      Parameters:
      request - the request
      options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized
      listener - the listener to be notified upon request completion
      Returns:
      cancellable that may be used to cancel the request