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.
Source Files