v2

package
v0.6.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 1, 2019 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMetricsService = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetricsService   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterMetricsServiceServer

func RegisterMetricsServiceServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetricsServiceClient

func NewMetricsServiceClient(cc *grpc.ClientConn) 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.

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 data effectively is a structured metadata. As a performance optimization this will
	// only be sent in the first message on the stream.
	Identifier *StreamMetricsMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// A list of metric entries
	EnvoyMetrics         []*prometheus.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() []*prometheus.MetricFamily

func (*StreamMetricsMessage) GetIdentifier

func (*StreamMetricsMessage) Marshal

func (m *StreamMetricsMessage) Marshal() (dAtA []byte, err error)

func (*StreamMetricsMessage) MarshalTo

func (m *StreamMetricsMessage) MarshalTo(dAtA []byte) (int, error)

func (*StreamMetricsMessage) ProtoMessage

func (*StreamMetricsMessage) ProtoMessage()

func (*StreamMetricsMessage) Reset

func (m *StreamMetricsMessage) Reset()

func (*StreamMetricsMessage) Size

func (m *StreamMetricsMessage) Size() (n int)

func (*StreamMetricsMessage) String

func (m *StreamMetricsMessage) String() string

func (*StreamMetricsMessage) Unmarshal

func (m *StreamMetricsMessage) Unmarshal(dAtA []byte) error

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 {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamMetricsMessageValidationError is the validation error returned by StreamMetricsMessage.Validate if the designated constraints aren't met.

func (StreamMetricsMessageValidationError) Error

Error satisfies the builtin error interface

type StreamMetricsMessage_Identifier

type StreamMetricsMessage_Identifier struct {
	// The node sending metrics over the stream.
	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 (*StreamMetricsMessage_Identifier) Marshal

func (m *StreamMetricsMessage_Identifier) Marshal() (dAtA []byte, err error)

func (*StreamMetricsMessage_Identifier) MarshalTo

func (m *StreamMetricsMessage_Identifier) MarshalTo(dAtA []byte) (int, error)

func (*StreamMetricsMessage_Identifier) ProtoMessage

func (*StreamMetricsMessage_Identifier) ProtoMessage()

func (*StreamMetricsMessage_Identifier) Reset

func (*StreamMetricsMessage_Identifier) Size

func (m *StreamMetricsMessage_Identifier) Size() (n int)

func (*StreamMetricsMessage_Identifier) String

func (*StreamMetricsMessage_Identifier) Unmarshal

func (m *StreamMetricsMessage_Identifier) Unmarshal(dAtA []byte) error

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 {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamMetricsMessage_IdentifierValidationError is the validation error returned by StreamMetricsMessage_Identifier.Validate if the designated constraints aren't met.

func (StreamMetricsMessage_IdentifierValidationError) Error

Error satisfies the builtin error interface

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) Marshal

func (m *StreamMetricsResponse) Marshal() (dAtA []byte, err error)

func (*StreamMetricsResponse) MarshalTo

func (m *StreamMetricsResponse) MarshalTo(dAtA []byte) (int, error)

func (*StreamMetricsResponse) ProtoMessage

func (*StreamMetricsResponse) ProtoMessage()

func (*StreamMetricsResponse) Reset

func (m *StreamMetricsResponse) Reset()

func (*StreamMetricsResponse) Size

func (m *StreamMetricsResponse) Size() (n int)

func (*StreamMetricsResponse) String

func (m *StreamMetricsResponse) String() string

func (*StreamMetricsResponse) Unmarshal

func (m *StreamMetricsResponse) Unmarshal(dAtA []byte) error

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 {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamMetricsResponseValidationError is the validation error returned by StreamMetricsResponse.Validate if the designated constraints aren't met.

func (StreamMetricsResponseValidationError) Error

Error satisfies the builtin error interface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL