Class AbstractV1EndpointsProvider

java.lang.Object
io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider
io.micronaut.kubernetes.discovery.provider.AbstractV1EndpointsProvider
All Implemented Interfaces:
KubernetesServiceInstanceProvider
Direct Known Subclasses:
KubernetesServiceInstanceEndpointInformerProvider, KubernetesServiceInstanceEndpointProvider

public abstract class AbstractV1EndpointsProvider extends AbstractKubernetesServiceInstanceProvider
Service instance provider uses Kubernetes Endpoints as source of service discovery.
Since:
3.2
Author:
Pavol Gressa
  • Field Details

  • Constructor Details

  • Method Details

    • getMode

      public String getMode()
      Returns:
      the provider mode name.
    • getServiceIds

      public org.reactivestreams.Publisher<String> getServiceIds(String namespace)
      Parameters:
      namespace - namespace
      Returns:
      provider service ids for given namespace
    • getInstances

      public org.reactivestreams.Publisher<List<io.micronaut.discovery.ServiceInstance>> getInstances(KubernetesServiceConfiguration serviceConfiguration)
      Parameters:
      serviceConfiguration - service discovery configuration
      Returns:
      discovered service instances
    • getEndpoints

      public abstract reactor.core.publisher.Mono<io.kubernetes.client.openapi.models.V1Endpoints> getEndpoints(String name, String namespace)
    • listEndpoints

      public abstract reactor.core.publisher.Flux<io.kubernetes.client.openapi.models.V1Endpoints> listEndpoints(String namespace)