Versions in this module Expand all Collapse all v0 v0.6.1 Oct 15, 2018 v0.6.0 Sep 25, 2018 v0.5.0 Aug 14, 2018 Changes in this version + var ErrIntOverflowMetricsService = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMetricsService = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer) + type MetricsServiceClient interface + StreamMetrics func(ctx context.Context, opts ...grpc.CallOption) (MetricsService_StreamMetricsClient, error) + func NewMetricsServiceClient(cc *grpc.ClientConn) MetricsServiceClient + type MetricsServiceServer interface + StreamMetrics func(MetricsService_StreamMetricsServer) error + type MetricsService_StreamMetricsClient interface + CloseAndRecv func() (*StreamMetricsResponse, error) + Send func(*StreamMetricsMessage) error + type MetricsService_StreamMetricsServer interface + Recv func() (*StreamMetricsMessage, error) + SendAndClose func(*StreamMetricsResponse) error + type StreamMetricsMessage struct + EnvoyMetrics []*prometheus.MetricFamily + Identifier *StreamMetricsMessage_Identifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamMetricsMessage) Descriptor() ([]byte, []int) + func (*StreamMetricsMessage) ProtoMessage() + func (dst *StreamMetricsMessage) XXX_Merge(src proto.Message) + func (m *StreamMetricsMessage) GetEnvoyMetrics() []*prometheus.MetricFamily + func (m *StreamMetricsMessage) GetIdentifier() *StreamMetricsMessage_Identifier + func (m *StreamMetricsMessage) Marshal() (dAtA []byte, err error) + func (m *StreamMetricsMessage) MarshalTo(dAtA []byte) (int, error) + func (m *StreamMetricsMessage) Reset() + func (m *StreamMetricsMessage) Size() (n int) + func (m *StreamMetricsMessage) String() string + func (m *StreamMetricsMessage) Unmarshal(dAtA []byte) error + func (m *StreamMetricsMessage) Validate() error + func (m *StreamMetricsMessage) XXX_DiscardUnknown() + func (m *StreamMetricsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamMetricsMessage) XXX_Size() int + func (m *StreamMetricsMessage) XXX_Unmarshal(b []byte) error + type StreamMetricsMessageValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamMetricsMessageValidationError) Error() string + type StreamMetricsMessage_Identifier struct + Node *core.Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamMetricsMessage_Identifier) Descriptor() ([]byte, []int) + func (*StreamMetricsMessage_Identifier) ProtoMessage() + func (dst *StreamMetricsMessage_Identifier) XXX_Merge(src proto.Message) + func (m *StreamMetricsMessage_Identifier) GetNode() *core.Node + func (m *StreamMetricsMessage_Identifier) Marshal() (dAtA []byte, err error) + func (m *StreamMetricsMessage_Identifier) MarshalTo(dAtA []byte) (int, error) + func (m *StreamMetricsMessage_Identifier) Reset() + func (m *StreamMetricsMessage_Identifier) Size() (n int) + func (m *StreamMetricsMessage_Identifier) String() string + func (m *StreamMetricsMessage_Identifier) Unmarshal(dAtA []byte) error + func (m *StreamMetricsMessage_Identifier) Validate() error + func (m *StreamMetricsMessage_Identifier) XXX_DiscardUnknown() + func (m *StreamMetricsMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamMetricsMessage_Identifier) XXX_Size() int + func (m *StreamMetricsMessage_Identifier) XXX_Unmarshal(b []byte) error + type StreamMetricsMessage_IdentifierValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamMetricsMessage_IdentifierValidationError) Error() string + type StreamMetricsResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamMetricsResponse) Descriptor() ([]byte, []int) + func (*StreamMetricsResponse) ProtoMessage() + func (dst *StreamMetricsResponse) XXX_Merge(src proto.Message) + func (m *StreamMetricsResponse) Marshal() (dAtA []byte, err error) + func (m *StreamMetricsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StreamMetricsResponse) Reset() + func (m *StreamMetricsResponse) Size() (n int) + func (m *StreamMetricsResponse) String() string + func (m *StreamMetricsResponse) Unmarshal(dAtA []byte) error + func (m *StreamMetricsResponse) Validate() error + func (m *StreamMetricsResponse) XXX_DiscardUnknown() + func (m *StreamMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamMetricsResponse) XXX_Size() int + func (m *StreamMetricsResponse) XXX_Unmarshal(b []byte) error + type StreamMetricsResponseValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamMetricsResponseValidationError) Error() string