Documentation ¶
Index ¶
- func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)
- type MetricsServiceClient
- type MetricsServiceServer
- type MetricsService_StreamMetricsClient
- type MetricsService_StreamMetricsServer
- type StreamMetricsMessage
- func (*StreamMetricsMessage) Descriptor() ([]byte, []int)
- func (m *StreamMetricsMessage) GetEnvoyMetrics() []*_go.MetricFamily
- func (m *StreamMetricsMessage) GetIdentifier() *StreamMetricsMessage_Identifier
- func (*StreamMetricsMessage) ProtoMessage()
- func (m *StreamMetricsMessage) Reset()
- func (m *StreamMetricsMessage) String() string
- 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_Merge(src proto.Message)
- func (m *StreamMetricsMessage) XXX_Size() int
- func (m *StreamMetricsMessage) XXX_Unmarshal(b []byte) error
- type StreamMetricsMessageValidationError
- func (e StreamMetricsMessageValidationError) Cause() error
- func (e StreamMetricsMessageValidationError) Error() string
- func (e StreamMetricsMessageValidationError) ErrorName() string
- func (e StreamMetricsMessageValidationError) Field() string
- func (e StreamMetricsMessageValidationError) Key() bool
- func (e StreamMetricsMessageValidationError) Reason() string
- type StreamMetricsMessage_Identifier
- func (*StreamMetricsMessage_Identifier) Descriptor() ([]byte, []int)
- func (m *StreamMetricsMessage_Identifier) GetNode() *core.Node
- func (*StreamMetricsMessage_Identifier) ProtoMessage()
- func (m *StreamMetricsMessage_Identifier) Reset()
- func (m *StreamMetricsMessage_Identifier) String() string
- 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_Merge(src proto.Message)
- func (m *StreamMetricsMessage_Identifier) XXX_Size() int
- func (m *StreamMetricsMessage_Identifier) XXX_Unmarshal(b []byte) error
- type StreamMetricsMessage_IdentifierValidationError
- func (e StreamMetricsMessage_IdentifierValidationError) Cause() error
- func (e StreamMetricsMessage_IdentifierValidationError) Error() string
- func (e StreamMetricsMessage_IdentifierValidationError) ErrorName() string
- func (e StreamMetricsMessage_IdentifierValidationError) Field() string
- func (e StreamMetricsMessage_IdentifierValidationError) Key() bool
- func (e StreamMetricsMessage_IdentifierValidationError) Reason() string
- type StreamMetricsResponse
- func (*StreamMetricsResponse) Descriptor() ([]byte, []int)
- func (*StreamMetricsResponse) ProtoMessage()
- func (m *StreamMetricsResponse) Reset()
- func (m *StreamMetricsResponse) String() string
- 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_Merge(src proto.Message)
- func (m *StreamMetricsResponse) XXX_Size() int
- func (m *StreamMetricsResponse) XXX_Unmarshal(b []byte) error
- type StreamMetricsResponseValidationError
- func (e StreamMetricsResponseValidationError) Cause() error
- func (e StreamMetricsResponseValidationError) Error() string
- func (e StreamMetricsResponseValidationError) ErrorName() string
- func (e StreamMetricsResponseValidationError) Field() string
- func (e StreamMetricsResponseValidationError) Key() bool
- func (e StreamMetricsResponseValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMetricsServiceServer ¶
func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)
Types ¶
type MetricsServiceClient ¶
type MetricsServiceClient interface {
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMetricsServiceClient ¶
func NewMetricsServiceClient(cc *grpc.ClientConn) MetricsServiceClient
type MetricsServiceServer ¶
type MetricsServiceServer interface {
StreamMetrics(MetricsService_StreamMetricsServer) error
}
MetricsServiceServer is the server API for MetricsService service.
type MetricsService_StreamMetricsClient ¶
type MetricsService_StreamMetricsClient interface { Send(*StreamMetricsMessage) error CloseAndRecv() (*StreamMetricsResponse, error) grpc.ClientStream }
type MetricsService_StreamMetricsServer ¶
type MetricsService_StreamMetricsServer interface { SendAndClose(*StreamMetricsResponse) error Recv() (*StreamMetricsMessage, error) grpc.ServerStream }
type StreamMetricsMessage ¶
type StreamMetricsMessage struct { Identifier *StreamMetricsMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` EnvoyMetrics []*_go.MetricFamily `protobuf:"bytes,2,rep,name=envoy_metrics,json=envoyMetrics,proto3" json:"envoy_metrics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamMetricsMessage) Descriptor ¶
func (*StreamMetricsMessage) Descriptor() ([]byte, []int)
func (*StreamMetricsMessage) GetEnvoyMetrics ¶
func (m *StreamMetricsMessage) GetEnvoyMetrics() []*_go.MetricFamily
func (*StreamMetricsMessage) GetIdentifier ¶
func (m *StreamMetricsMessage) GetIdentifier() *StreamMetricsMessage_Identifier
func (*StreamMetricsMessage) ProtoMessage ¶
func (*StreamMetricsMessage) ProtoMessage()
func (*StreamMetricsMessage) Reset ¶
func (m *StreamMetricsMessage) Reset()
func (*StreamMetricsMessage) String ¶
func (m *StreamMetricsMessage) String() string
func (*StreamMetricsMessage) Validate ¶
func (m *StreamMetricsMessage) Validate() error
Validate checks the field values on StreamMetricsMessage with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamMetricsMessage) XXX_DiscardUnknown ¶
func (m *StreamMetricsMessage) XXX_DiscardUnknown()
func (*StreamMetricsMessage) XXX_Marshal ¶
func (m *StreamMetricsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamMetricsMessage) XXX_Merge ¶
func (m *StreamMetricsMessage) XXX_Merge(src proto.Message)
func (*StreamMetricsMessage) XXX_Size ¶
func (m *StreamMetricsMessage) XXX_Size() int
func (*StreamMetricsMessage) XXX_Unmarshal ¶
func (m *StreamMetricsMessage) XXX_Unmarshal(b []byte) error
type StreamMetricsMessageValidationError ¶
type StreamMetricsMessageValidationError struct {
// contains filtered or unexported fields
}
StreamMetricsMessageValidationError is the validation error returned by StreamMetricsMessage.Validate if the designated constraints aren't met.
func (StreamMetricsMessageValidationError) Cause ¶
func (e StreamMetricsMessageValidationError) Cause() error
Cause function returns cause value.
func (StreamMetricsMessageValidationError) Error ¶
func (e StreamMetricsMessageValidationError) Error() string
Error satisfies the builtin error interface
func (StreamMetricsMessageValidationError) ErrorName ¶ added in v0.7.0
func (e StreamMetricsMessageValidationError) ErrorName() string
ErrorName returns error name.
func (StreamMetricsMessageValidationError) Field ¶
func (e StreamMetricsMessageValidationError) Field() string
Field function returns field value.
func (StreamMetricsMessageValidationError) Key ¶
func (e StreamMetricsMessageValidationError) Key() bool
Key function returns key value.
func (StreamMetricsMessageValidationError) Reason ¶
func (e StreamMetricsMessageValidationError) Reason() string
Reason function returns reason value.
type StreamMetricsMessage_Identifier ¶
type StreamMetricsMessage_Identifier struct { Node *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamMetricsMessage_Identifier) Descriptor ¶
func (*StreamMetricsMessage_Identifier) Descriptor() ([]byte, []int)
func (*StreamMetricsMessage_Identifier) GetNode ¶
func (m *StreamMetricsMessage_Identifier) GetNode() *core.Node
func (*StreamMetricsMessage_Identifier) ProtoMessage ¶
func (*StreamMetricsMessage_Identifier) ProtoMessage()
func (*StreamMetricsMessage_Identifier) Reset ¶
func (m *StreamMetricsMessage_Identifier) Reset()
func (*StreamMetricsMessage_Identifier) String ¶
func (m *StreamMetricsMessage_Identifier) String() string
func (*StreamMetricsMessage_Identifier) Validate ¶
func (m *StreamMetricsMessage_Identifier) Validate() error
Validate checks the field values on StreamMetricsMessage_Identifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamMetricsMessage_Identifier) XXX_DiscardUnknown ¶
func (m *StreamMetricsMessage_Identifier) XXX_DiscardUnknown()
func (*StreamMetricsMessage_Identifier) XXX_Marshal ¶
func (m *StreamMetricsMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamMetricsMessage_Identifier) XXX_Merge ¶
func (m *StreamMetricsMessage_Identifier) XXX_Merge(src proto.Message)
func (*StreamMetricsMessage_Identifier) XXX_Size ¶
func (m *StreamMetricsMessage_Identifier) XXX_Size() int
func (*StreamMetricsMessage_Identifier) XXX_Unmarshal ¶
func (m *StreamMetricsMessage_Identifier) XXX_Unmarshal(b []byte) error
type StreamMetricsMessage_IdentifierValidationError ¶
type StreamMetricsMessage_IdentifierValidationError struct {
// contains filtered or unexported fields
}
StreamMetricsMessage_IdentifierValidationError is the validation error returned by StreamMetricsMessage_Identifier.Validate if the designated constraints aren't met.
func (StreamMetricsMessage_IdentifierValidationError) Cause ¶
func (e StreamMetricsMessage_IdentifierValidationError) Cause() error
Cause function returns cause value.
func (StreamMetricsMessage_IdentifierValidationError) Error ¶
func (e StreamMetricsMessage_IdentifierValidationError) Error() string
Error satisfies the builtin error interface
func (StreamMetricsMessage_IdentifierValidationError) ErrorName ¶ added in v0.7.0
func (e StreamMetricsMessage_IdentifierValidationError) ErrorName() string
ErrorName returns error name.
func (StreamMetricsMessage_IdentifierValidationError) Field ¶
func (e StreamMetricsMessage_IdentifierValidationError) Field() string
Field function returns field value.
func (StreamMetricsMessage_IdentifierValidationError) Key ¶
func (e StreamMetricsMessage_IdentifierValidationError) Key() bool
Key function returns key value.
func (StreamMetricsMessage_IdentifierValidationError) Reason ¶
func (e StreamMetricsMessage_IdentifierValidationError) Reason() string
Reason function returns reason value.
type StreamMetricsResponse ¶
type StreamMetricsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamMetricsResponse) Descriptor ¶
func (*StreamMetricsResponse) Descriptor() ([]byte, []int)
func (*StreamMetricsResponse) ProtoMessage ¶
func (*StreamMetricsResponse) ProtoMessage()
func (*StreamMetricsResponse) Reset ¶
func (m *StreamMetricsResponse) Reset()
func (*StreamMetricsResponse) String ¶
func (m *StreamMetricsResponse) String() string
func (*StreamMetricsResponse) Validate ¶
func (m *StreamMetricsResponse) Validate() error
Validate checks the field values on StreamMetricsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamMetricsResponse) XXX_DiscardUnknown ¶
func (m *StreamMetricsResponse) XXX_DiscardUnknown()
func (*StreamMetricsResponse) XXX_Marshal ¶
func (m *StreamMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamMetricsResponse) XXX_Merge ¶
func (m *StreamMetricsResponse) XXX_Merge(src proto.Message)
func (*StreamMetricsResponse) XXX_Size ¶
func (m *StreamMetricsResponse) XXX_Size() int
func (*StreamMetricsResponse) XXX_Unmarshal ¶
func (m *StreamMetricsResponse) XXX_Unmarshal(b []byte) error
type StreamMetricsResponseValidationError ¶
type StreamMetricsResponseValidationError struct {
// contains filtered or unexported fields
}
StreamMetricsResponseValidationError is the validation error returned by StreamMetricsResponse.Validate if the designated constraints aren't met.
func (StreamMetricsResponseValidationError) Cause ¶
func (e StreamMetricsResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamMetricsResponseValidationError) Error ¶
func (e StreamMetricsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamMetricsResponseValidationError) ErrorName ¶ added in v0.7.0
func (e StreamMetricsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamMetricsResponseValidationError) Field ¶
func (e StreamMetricsResponseValidationError) Field() string
Field function returns field value.
func (StreamMetricsResponseValidationError) Key ¶
func (e StreamMetricsResponseValidationError) Key() bool
Key function returns key value.
func (StreamMetricsResponseValidationError) Reason ¶
func (e StreamMetricsResponseValidationError) Reason() string
Reason function returns reason value.