Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterClientStatusDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ClientStatusDiscoveryServiceServer)
- type ClientStatusDiscoveryServiceClient
- type ClientStatusDiscoveryServiceServer
- type ClientStatusDiscoveryService_StreamClientStatusClient
- type ClientStatusDiscoveryService_StreamClientStatusServer
- type UnimplementedClientStatusDiscoveryServiceServer
- type UnsafeClientStatusDiscoveryServiceServer
Constants ¶
const ( ClientStatusDiscoveryService_StreamClientStatus_FullMethodName = "/envoy.service.status.v2.ClientStatusDiscoveryService/StreamClientStatus" ClientStatusDiscoveryService_FetchClientStatus_FullMethodName = "/envoy.service.status.v2.ClientStatusDiscoveryService/FetchClientStatus" )
Variables ¶
var ClientStatusDiscoveryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.status.v2.ClientStatusDiscoveryService", HandlerType: (*ClientStatusDiscoveryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FetchClientStatus", Handler: _ClientStatusDiscoveryService_FetchClientStatus_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamClientStatus", Handler: _ClientStatusDiscoveryService_StreamClientStatus_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "envoy/service/status/v2/csds.proto", }
ClientStatusDiscoveryService_ServiceDesc is the grpc.ServiceDesc for ClientStatusDiscoveryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterClientStatusDiscoveryServiceServer ¶
func RegisterClientStatusDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ClientStatusDiscoveryServiceServer)
Types ¶
type ClientStatusDiscoveryServiceClient ¶
type ClientStatusDiscoveryServiceClient interface { StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error) FetchClientStatus(ctx context.Context, in *v2.ClientStatusRequest, opts ...grpc.CallOption) (*v2.ClientStatusResponse, error) }
ClientStatusDiscoveryServiceClient is the client API for ClientStatusDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
CSDS is Client Status Discovery Service. It can be used to get the status of an xDS-compliant client from the management server's point of view. In the future, it can potentially be used as an interface to get the current state directly from the client.
func NewClientStatusDiscoveryServiceClient ¶
func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient
type ClientStatusDiscoveryServiceServer ¶
type ClientStatusDiscoveryServiceServer interface { StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error FetchClientStatus(context.Context, *v2.ClientStatusRequest) (*v2.ClientStatusResponse, error) }
ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service. All implementations should embed UnimplementedClientStatusDiscoveryServiceServer for forward compatibility
CSDS is Client Status Discovery Service. It can be used to get the status of an xDS-compliant client from the management server's point of view. In the future, it can potentially be used as an interface to get the current state directly from the client.
type ClientStatusDiscoveryService_StreamClientStatusClient ¶
type ClientStatusDiscoveryService_StreamClientStatusClient interface { Send(*v2.ClientStatusRequest) error Recv() (*v2.ClientStatusResponse, error) grpc.ClientStream }
type ClientStatusDiscoveryService_StreamClientStatusServer ¶
type ClientStatusDiscoveryService_StreamClientStatusServer interface { Send(*v2.ClientStatusResponse) error Recv() (*v2.ClientStatusRequest, error) grpc.ServerStream }
type UnimplementedClientStatusDiscoveryServiceServer ¶
type UnimplementedClientStatusDiscoveryServiceServer struct { }
UnimplementedClientStatusDiscoveryServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus ¶
func (UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *v2.ClientStatusRequest) (*v2.ClientStatusResponse, error)
func (UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus ¶
func (UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
type UnsafeClientStatusDiscoveryServiceServer ¶
type UnsafeClientStatusDiscoveryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClientStatusDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClientStatusDiscoveryServiceServer will result in compilation errors.