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
All Methods Static Methods Instance Methods Concrete Methods 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.
-
-
-
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 interfaceio.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)
-
-