csds

Documentation

Overview

Package csds implements features to dump the status (xDS responses) the xds_client is using.

Notice: This package is EXPERIMENTAL and may be changed or removed in a later release.

Index

• type ClientStatusDiscoveryServer
  • func NewClientStatusDiscoveryServer() (*ClientStatusDiscoveryServer, error)
  • func (s *ClientStatusDiscoveryServer) Close()
  • func (s *ClientStatusDiscoveryServer) FetchClientStatus(_ context.Context, req *v3statuspb.ClientStatusRequest) (*v3statuspb.ClientStatusResponse, error)
  • func (s *ClientStatusDiscoveryServer) StreamClientStatus(stream v3statusgrpc.ClientStatusDiscoveryService_StreamClientStatusServer) error

Types

type ClientStatusDiscoveryServer

type ClientStatusDiscoveryServer struct {
	// contains filtered or unexported fields
}

ClientStatusDiscoveryServer implementations interface ClientStatusDiscoveryServiceServer.

func NewClientStatusDiscoveryServer

func NewClientStatusDiscoveryServer() (*ClientStatusDiscoveryServer, error)

NewClientStatusDiscoveryServer returns an implementation of the CSDS server that can be registered on a gRPC server.

func (*ClientStatusDiscoveryServer) Close

func (s *ClientStatusDiscoveryServer) Close()

Close cleans up the resources.

func (*ClientStatusDiscoveryServer) FetchClientStatus

func (s *ClientStatusDiscoveryServer) FetchClientStatus(_ context.Context, req *v3statuspb.ClientStatusRequest) (*v3statuspb.ClientStatusResponse, error)

FetchClientStatus implementations interface ClientStatusDiscoveryServiceServer.

func (*ClientStatusDiscoveryServer) StreamClientStatus

func (s *ClientStatusDiscoveryServer) StreamClientStatus(stream v3statusgrpc.ClientStatusDiscoveryService_StreamClientStatusServer) error

StreamClientStatus implementations interface ClientStatusDiscoveryServiceServer.