Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)
- type MetricsServiceClient
- type MetricsServiceServer
- type MetricsService_StreamMetricsClient
- type MetricsService_StreamMetricsServer
- type UnimplementedMetricsServiceServer
- type UnsafeMetricsServiceServer
Constants ¶
const (
MetricsService_StreamMetrics_FullMethodName = "/envoy.service.metrics.v3.MetricsService/StreamMetrics"
)
Variables ¶
var MetricsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.metrics.v3.MetricsService", HandlerType: (*MetricsServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "StreamMetrics", Handler: _MetricsService_StreamMetrics_Handler, ClientStreams: true, }, }, Metadata: "envoy/service/metrics/v3/metrics_service.proto", }
MetricsService_ServiceDesc is the grpc.ServiceDesc for MetricsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMetricsServiceServer ¶
func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)
Types ¶
type MetricsServiceClient ¶
type MetricsServiceClient interface { // Envoy will connect and send StreamMetricsMessage messages forever. It does not expect any // response to be sent as nothing would be done in the case of failure. StreamMetrics(ctx context.Context, opts ...grpc.CallOption) (MetricsService_StreamMetricsClient, error) }
MetricsServiceClient is the client API for MetricsService 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.
func NewMetricsServiceClient ¶
func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient
type MetricsServiceServer ¶
type MetricsServiceServer interface { // Envoy will connect and send StreamMetricsMessage messages forever. It does not expect any // response to be sent as nothing would be done in the case of failure. StreamMetrics(MetricsService_StreamMetricsServer) error }
MetricsServiceServer is the server API for MetricsService service. All implementations should embed UnimplementedMetricsServiceServer for forward compatibility
type MetricsService_StreamMetricsClient ¶
type MetricsService_StreamMetricsClient interface { Send(*v3.StreamMetricsMessage) error CloseAndRecv() (*v3.StreamMetricsResponse, error) grpc.ClientStream }
type MetricsService_StreamMetricsServer ¶
type MetricsService_StreamMetricsServer interface { SendAndClose(*v3.StreamMetricsResponse) error Recv() (*v3.StreamMetricsMessage, error) grpc.ServerStream }
type UnimplementedMetricsServiceServer ¶
type UnimplementedMetricsServiceServer struct { }
UnimplementedMetricsServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedMetricsServiceServer) StreamMetrics ¶
func (UnimplementedMetricsServiceServer) StreamMetrics(MetricsService_StreamMetricsServer) error
type UnsafeMetricsServiceServer ¶
type UnsafeMetricsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMetricsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsServiceServer will result in compilation errors.