envoy_service_metrics_v2

Documentation

Index

• func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)
• type MetricsServiceClient
  • func NewMetricsServiceClient(cc *grpc.ClientConn) 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) 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 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) 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 StreamMetricsResponse
  • func (*StreamMetricsResponse) Descriptor() ([]byte, []int)
  • func (*StreamMetricsResponse) ProtoMessage()
  • func (m *StreamMetricsResponse) Reset()
  • func (m *StreamMetricsResponse) String() string
  • 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

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         []*_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) 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 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 (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) 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 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) 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