Package com.linecorp.centraldogma.xds.k8s.v1

Class XdsKubernetesService

java.lang.Object

com.linecorp.centraldogma.xds.k8s.v1.XdsKubernetesServiceGrpc.XdsKubernetesServiceImplBase

com.linecorp.centraldogma.xds.k8s.v1.XdsKubernetesService

All Implemented Interfaces:

com.linecorp.centraldogma.xds.k8s.v1.XdsKubernetesServiceGrpc.AsyncService, io.grpc.BindableService

public final class XdsKubernetesService
extends com.linecorp.centraldogma.xds.k8s.v1.XdsKubernetesServiceGrpc.XdsKubernetesServiceImplBase

A gRPC service that handles Kubernetes resources.

Field Summary

Fields

Modifier and Type	Field	Description
static final Pattern	AGGREGATORS_REPLCACE_PATTERN
static final CompletableFuture<?>[]	EMPTY_FUTURES
static final Pattern	K8S_ENDPOINT_AGGREGATORS_NAME_PATTERN

Constructor Summary

Constructors

Constructor	Description
XdsKubernetesService(com.linecorp.centraldogma.xds.internal.XdsResourceManager xdsResourceManager)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
void	createKubernetesEndpointAggregator(com.linecorp.centraldogma.xds.k8s.v1.CreateKubernetesEndpointAggregatorRequest request, io.grpc.stub.StreamObserver<com.linecorp.centraldogma.xds.k8s.v1.KubernetesEndpointAggregator> responseObserver)
static CompletableFuture<com.linecorp.armeria.client.kubernetes.endpoints.KubernetesEndpointGroup>	createKubernetesEndpointGroup(com.linecorp.centraldogma.xds.k8s.v1.ServiceEndpointWatcher watcher, MetaRepository metaRepository, Executor executor)	Creates a KubernetesEndpointGroup from the specified ServiceEndpointWatcher.
void	deleteKubernetesEndpointAggregator(com.linecorp.centraldogma.xds.k8s.v1.DeleteKubernetesEndpointAggregatorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	updateKubernetesEndpointAggregator(com.linecorp.centraldogma.xds.k8s.v1.UpdateKubernetesEndpointAggregatorRequest request, io.grpc.stub.StreamObserver<com.linecorp.centraldogma.xds.k8s.v1.KubernetesEndpointAggregator> responseObserver)

Methods inherited from class com.linecorp.centraldogma.xds.k8s.v1.XdsKubernetesServiceGrpc.XdsKubernetesServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Field Details

AGGREGATORS_REPLCACE_PATTERN

public static final Pattern AGGREGATORS_REPLCACE_PATTERN

K8S_ENDPOINT_AGGREGATORS_NAME_PATTERN

public static final Pattern K8S_ENDPOINT_AGGREGATORS_NAME_PATTERN

EMPTY_FUTURES

public static final CompletableFuture<?>[] EMPTY_FUTURES

Constructor Details

XdsKubernetesService

public XdsKubernetesService(com.linecorp.centraldogma.xds.internal.XdsResourceManager xdsResourceManager)

Creates a new instance.

Method Details

createKubernetesEndpointAggregator

public void createKubernetesEndpointAggregator(com.linecorp.centraldogma.xds.k8s.v1.CreateKubernetesEndpointAggregatorRequest request,
 io.grpc.stub.StreamObserver<com.linecorp.centraldogma.xds.k8s.v1.KubernetesEndpointAggregator> responseObserver)

createKubernetesEndpointGroup

public static CompletableFuture<com.linecorp.armeria.client.kubernetes.endpoints.KubernetesEndpointGroup> createKubernetesEndpointGroup(com.linecorp.centraldogma.xds.k8s.v1.ServiceEndpointWatcher watcher,
 MetaRepository metaRepository,
 Executor executor)

Creates a KubernetesEndpointGroup from the specified ServiceEndpointWatcher. This method must be executed in a blocking thread because KubernetesEndpointGroupBuilder.build() blocks the execution thread.

updateKubernetesEndpointAggregator

public void updateKubernetesEndpointAggregator(com.linecorp.centraldogma.xds.k8s.v1.UpdateKubernetesEndpointAggregatorRequest request,
 io.grpc.stub.StreamObserver<com.linecorp.centraldogma.xds.k8s.v1.KubernetesEndpointAggregator> responseObserver)

deleteKubernetesEndpointAggregator

public void deleteKubernetesEndpointAggregator(com.linecorp.centraldogma.xds.k8s.v1.DeleteKubernetesEndpointAggregatorRequest request,
 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)