Class RmHealthProbeClientImpl

java.lang.Object
io.confluent.rm.kafka.v1.RmHealthProbeClientImpl
All Implemented Interfaces:
RmHealthProbeClient
public class RmHealthProbeClientImpl extends Object implements RmHealthProbeClient
Implementation of RmHealthProbeClient using RmClient.

Manages the synthetic HealthProbe resources used for per-broker metadata healthchecks. HealthProbe is Environment-scoped ([org, environment]); the scope is embedded in the ObjectIdentifier passed to each operation, following the same identifier-scope convention as RmGroupConfigClientImpl.

  • Constructor Summary

    Constructors
    Constructor
    Description
    RmHealthProbeClientImpl(RmClient client)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<io.confluent.rm.kafka.v1.HealthProbe>
    createHealthProbe(io.confluent.rm.kafka.v1.HealthProbe healthProbe)
    Creates a new HealthProbe resource in the resource manager.
    CompletableFuture<Optional<io.confluent.rm.kafka.v1.HealthProbe>>
    deleteHealthProbe(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.HealthProbe> id)
    Deletes a HealthProbe resource from the resource manager.
    CompletableFuture<Optional<io.confluent.rm.kafka.v1.HealthProbe>>
    getHealthProbe(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.HealthProbe> id)
    Retrieves a HealthProbe resource from the resource manager.
    RmWatcher<io.confluent.rm.kafka.v1.HealthProbe>
    healthProbeWatch()
    Creates a watcher for monitoring HealthProbe changes in the resource manager.
    CompletableFuture<io.confluent.resourcemanager.api.model.ObjectList<io.confluent.rm.kafka.v1.HealthProbe>>
    listHealthProbes(List<io.confluent.resourcemanager.protobuf.apis.meta.v1.ScopeAttribute> scope, String continueToken)
    Lists a single page of HealthProbe resources in the given scope.

    Methods inherited from class Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RmHealthProbeClientImpl

      public RmHealthProbeClientImpl(RmClient client)

  • Method Details

    • createHealthProbe

      public CompletableFuture<io.confluent.rm.kafka.v1.HealthProbe> createHealthProbe(io.confluent.rm.kafka.v1.HealthProbe healthProbe)
      Description copied from interface: RmHealthProbeClient
      Creates a new HealthProbe resource in the resource manager.
      Specified by:
      createHealthProbe in interface RmHealthProbeClient
      Parameters:
      healthProbe - the HealthProbe to create
      Returns:
      a CompletableFuture that completes with the created HealthProbe

    • getHealthProbe

      public CompletableFuture<Optional<io.confluent.rm.kafka.v1.HealthProbe>> getHealthProbe(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.HealthProbe> id)
      Description copied from interface: RmHealthProbeClient
      Retrieves a HealthProbe resource from the resource manager.
      Specified by:
      getHealthProbe in interface RmHealthProbeClient
      Parameters:
      id - the identifier of the HealthProbe to retrieve, with environment scope attributes
      Returns:
      a CompletableFuture that completes with an Optional containing the HealthProbe, or empty if the HealthProbe was not found

    • deleteHealthProbe

      public CompletableFuture<Optional<io.confluent.rm.kafka.v1.HealthProbe>> deleteHealthProbe(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.HealthProbe> id)
      Description copied from interface: RmHealthProbeClient
      Deletes a HealthProbe resource from the resource manager.
      Specified by:
      deleteHealthProbe in interface RmHealthProbeClient
      Parameters:
      id - the identifier of the HealthProbe to delete, with environment scope attributes
      Returns:
      a CompletableFuture that completes with an Optional containing the deleted HealthProbe, or empty if the HealthProbe was not found

    • listHealthProbes

      public CompletableFuture<io.confluent.resourcemanager.api.model.ObjectList<io.confluent.rm.kafka.v1.HealthProbe>> listHealthProbes(List<io.confluent.resourcemanager.protobuf.apis.meta.v1.ScopeAttribute> scope, String continueToken)
      Description copied from interface: RmHealthProbeClient
      Lists a single page of HealthProbe resources in the given scope. Pass a null/empty continueToken for the first page, or the continue token from a previous page's ListMeta to fetch the next page.
      Specified by:
      listHealthProbes in interface RmHealthProbeClient
      Parameters:
      scope - the scope attributes to list within
      continueToken - the continuation token from a previous page, or null/empty for the first
      Returns:
      a CompletableFuture that completes with the page of HealthProbe resources in the scope

    • healthProbeWatch

      public RmWatcher<io.confluent.rm.kafka.v1.HealthProbe> healthProbeWatch()
      Description copied from interface: RmHealthProbeClient
      Creates a watcher for monitoring HealthProbe changes in the resource manager.
      Specified by:
      healthProbeWatch in interface RmHealthProbeClient
      Returns:
      a Watcher that notifies of HealthProbe creation, modification, and deletion events