Package org.springframework.data.elasticsearch.client.erhlc

Interface ReactiveElasticsearchClient.Cluster

All Known Implementing Classes:
DefaultReactiveElasticsearchClient
Enclosing interface:
ReactiveElasticsearchClient
public static interface ReactiveElasticsearchClient.Cluster
Encapsulation of methods for accessing the Cluster API.
Since:
4.2
Author:
Peter-Josef Meisch

  • Method Summary

    Modifier and Type
    Method
    Description
    default reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse>
    health(Consumer<org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest> consumer)
    Execute the given {ClusterHealthRequest} against the cluster API.
    default reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse>
    health(org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest clusterHealthRequest)
    Execute the given {ClusterHealthRequest} against the cluster API.
    reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse>
    health(HttpHeaders headers, org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest clusterHealthRequest)
    Execute the given {ClusterHealthRequest} against the cluster API.

  • Method Details

    • health

      default reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse> health(Consumer<org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest> consumer)
      Execute the given {ClusterHealthRequest} against the cluster API.
      Parameters:
      consumer - never null.
      Returns:
      Mono emitting the ClusterHealthResponse.

    • health

      default reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse> health(org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest clusterHealthRequest)
      Execute the given {ClusterHealthRequest} against the cluster API.
      Parameters:
      clusterHealthRequest - must not be null // * @return Mono emitting the ClusterHealthResponse.

    • health

      reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse> health(HttpHeaders headers, org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest clusterHealthRequest)
      Execute the given {ClusterHealthRequest} against the cluster API.
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      clusterHealthRequest - must not be null // * @return Mono emitting the ClusterHealthResponse.