Package io.grpc.xds

Class CsdsService

java.lang.Object

io.grpc.xds.CsdsService

All Implemented Interfaces:

io.grpc.BindableService

public final class CsdsService
extends java.lang.Object
implements io.grpc.BindableService

The CSDS service provides information about the status of a running xDS client.

Client Status Discovery Service is a service that exposes xDS config of a given client. See the full design at gRFC A40: xDS Configuration Dump via Client Status Discovery Service in gRPC.

Since:

1.37.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	CsdsService.CsdsServiceInternal	Hide protobuf from being exposed via the API.

Field Summary

Fields

Modifier and Type	Field	Description
private CsdsService.CsdsServiceInternal	delegate
private static java.util.logging.Logger	logger
private XdsClientPoolFactory	xdsClientPoolFactory

Constructor Summary

Constructors

Modifier	Constructor	Description
private	CsdsService()
(package private)	CsdsService(XdsClientPoolFactory xdsClientPoolFactory)

Method Summary

Modifier and Type	Method	Description
private static java.util.Map<XdsResourceType<?>,java.util.Map<java.lang.String,XdsClient.ResourceMetadata>>	awaitSubscribedResourcesMetadata(com.google.common.util.concurrent.ListenableFuture<java.util.Map<XdsResourceType<?>,java.util.Map<java.lang.String,XdsClient.ResourceMetadata>>> future)
io.grpc.ServerServiceDefinition	bindService()
(package private) static ClientConfig	getClientConfigForXdsClient(XdsClient xdsClient, java.lang.String target)
private ClientConfig	getConfigForRequest(java.lang.String target)
private ClientStatusResponse	getStatusResponse(java.util.List<ClientConfig> clientConfigs)
private boolean	handleRequest(ClientStatusRequest request, io.grpc.stub.StreamObserver<ClientStatusResponse> responseObserver)
(package private) static ClientResourceStatus	metadataStatusToClientStatus(XdsClient.ResourceMetadata.ResourceMetadataStatus status)
private static UpdateFailureState	metadataUpdateFailureStateToProto(XdsClient.ResourceMetadata.UpdateFailureState errorState)
static CsdsService	newInstance()	Creates an instance.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final java.util.logging.Logger logger

xdsClientPoolFactory

private final XdsClientPoolFactory xdsClientPoolFactory

delegate

private final CsdsService.CsdsServiceInternal delegate

Constructor Detail

CsdsService

CsdsService(XdsClientPoolFactory xdsClientPoolFactory)

CsdsService

private CsdsService()

Method Detail

newInstance

public static CsdsService newInstance()

Creates an instance.

bindService

public io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService

handleRequest

private boolean handleRequest(ClientStatusRequest request,
                              io.grpc.stub.StreamObserver<ClientStatusResponse> responseObserver)

getConfigForRequest

private ClientConfig getConfigForRequest(java.lang.String target)
                                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getStatusResponse

private ClientStatusResponse getStatusResponse(java.util.List<ClientConfig> clientConfigs)

getClientConfigForXdsClient

static ClientConfig getClientConfigForXdsClient(XdsClient xdsClient,
                                                java.lang.String target)
                                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

awaitSubscribedResourcesMetadata

private static java.util.Map<XdsResourceType<?>,java.util.Map<java.lang.String,XdsClient.ResourceMetadata>> awaitSubscribedResourcesMetadata(com.google.common.util.concurrent.ListenableFuture<java.util.Map<XdsResourceType<?>,java.util.Map<java.lang.String,XdsClient.ResourceMetadata>>> future)
                                                                                                                                                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

metadataStatusToClientStatus

static ClientResourceStatus metadataStatusToClientStatus(XdsClient.ResourceMetadata.ResourceMetadataStatus status)

metadataUpdateFailureStateToProto

private static UpdateFailureState metadataUpdateFailureStateToProto(XdsClient.ResourceMetadata.UpdateFailureState errorState)