Documentation ¶
Index ¶
- Variables
- func RegisterMetricsExporterServer(s *grpc.Server, srv MetricsExporterServer)
- type CloudContext
- type Context
- func (*Context) Descriptor() ([]byte, []int)deprecated
- func (x *Context) GetCloudMetric() *CloudContext
- func (x *Context) GetGatewayMetric() *GatewayContext
- func (x *Context) GetMetricName() string
- func (m *Context) GetOriginContext() isContext_OriginContext
- func (x *Context) GetPushedMetric() *PushedContext
- func (*Context) ProtoMessage()
- func (x *Context) ProtoReflect() protoreflect.Message
- func (x *Context) Reset()
- func (x *Context) String() string
- type Context_CloudMetric
- type Context_GatewayMetric
- type Context_PushedMetric
- type ContextualizedMetric
- func (*ContextualizedMetric) Descriptor() ([]byte, []int)deprecated
- func (x *ContextualizedMetric) GetContext() *Context
- func (x *ContextualizedMetric) GetFamily() *_go.MetricFamily
- func (*ContextualizedMetric) ProtoMessage()
- func (x *ContextualizedMetric) ProtoReflect() protoreflect.Message
- func (x *ContextualizedMetric) Reset()
- func (x *ContextualizedMetric) String() string
- type GatewayContext
- func (*GatewayContext) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayContext) GetGatewayId() string
- func (x *GatewayContext) GetNetworkId() string
- func (*GatewayContext) ProtoMessage()
- func (x *GatewayContext) ProtoReflect() protoreflect.Message
- func (x *GatewayContext) Reset()
- func (x *GatewayContext) String() string
- type MetricsExporterClient
- type MetricsExporterServer
- type PushedContext
- type SubmitMetricsRequest
- func (*SubmitMetricsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitMetricsRequest) GetMetrics() []*ContextualizedMetric
- func (*SubmitMetricsRequest) ProtoMessage()
- func (x *SubmitMetricsRequest) ProtoReflect() protoreflect.Message
- func (x *SubmitMetricsRequest) Reset()
- func (x *SubmitMetricsRequest) String() string
- type SubmitMetricsResponse
- type UnimplementedMetricsExporterServer
Constants ¶
This section is empty.
Variables ¶
var File_exporter_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMetricsExporterServer ¶
func RegisterMetricsExporterServer(s *grpc.Server, srv MetricsExporterServer)
Types ¶
type CloudContext ¶
type CloudContext struct { CloudHost string `protobuf:"bytes,1,opt,name=cloud_host,json=cloudHost,proto3" json:"cloud_host,omitempty"` // contains filtered or unexported fields }
CloudContext contains context for metrics scraped from cloud services.
func (*CloudContext) Descriptor
deprecated
func (*CloudContext) Descriptor() ([]byte, []int)
Deprecated: Use CloudContext.ProtoReflect.Descriptor instead.
func (*CloudContext) GetCloudHost ¶
func (x *CloudContext) GetCloudHost() string
func (*CloudContext) ProtoMessage ¶
func (*CloudContext) ProtoMessage()
func (*CloudContext) ProtoReflect ¶
func (x *CloudContext) ProtoReflect() protoreflect.Message
func (*CloudContext) Reset ¶
func (x *CloudContext) Reset()
func (*CloudContext) String ¶
func (x *CloudContext) String() string
type Context ¶
type Context struct { MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"` // Types that are assignable to OriginContext: // *Context_CloudMetric // *Context_GatewayMetric // *Context_PushedMetric OriginContext isContext_OriginContext `protobuf_oneof:"OriginContext"` // contains filtered or unexported fields }
Context provides information to the exporter about a metric's origin.
func (*Context) Descriptor
deprecated
func (*Context) GetCloudMetric ¶
func (x *Context) GetCloudMetric() *CloudContext
func (*Context) GetGatewayMetric ¶
func (x *Context) GetGatewayMetric() *GatewayContext
func (*Context) GetMetricName ¶
func (*Context) GetOriginContext ¶
func (m *Context) GetOriginContext() isContext_OriginContext
func (*Context) GetPushedMetric ¶
func (x *Context) GetPushedMetric() *PushedContext
func (*Context) ProtoMessage ¶
func (*Context) ProtoMessage()
func (*Context) ProtoReflect ¶
func (x *Context) ProtoReflect() protoreflect.Message
type Context_CloudMetric ¶
type Context_CloudMetric struct {
CloudMetric *CloudContext `protobuf:"bytes,2,opt,name=cloud_metric,json=cloudMetric,proto3,oneof"`
}
type Context_GatewayMetric ¶
type Context_GatewayMetric struct {
GatewayMetric *GatewayContext `protobuf:"bytes,3,opt,name=gateway_metric,json=gatewayMetric,proto3,oneof"`
}
type Context_PushedMetric ¶
type Context_PushedMetric struct {
PushedMetric *PushedContext `protobuf:"bytes,4,opt,name=pushed_metric,json=pushedMetric,proto3,oneof"`
}
type ContextualizedMetric ¶
type ContextualizedMetric struct { Family *_go.MetricFamily `protobuf:"bytes,1,opt,name=family,proto3" json:"family,omitempty"` Context *Context `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` // contains filtered or unexported fields }
func (*ContextualizedMetric) Descriptor
deprecated
func (*ContextualizedMetric) Descriptor() ([]byte, []int)
Deprecated: Use ContextualizedMetric.ProtoReflect.Descriptor instead.
func (*ContextualizedMetric) GetContext ¶
func (x *ContextualizedMetric) GetContext() *Context
func (*ContextualizedMetric) GetFamily ¶
func (x *ContextualizedMetric) GetFamily() *_go.MetricFamily
func (*ContextualizedMetric) ProtoMessage ¶
func (*ContextualizedMetric) ProtoMessage()
func (*ContextualizedMetric) ProtoReflect ¶
func (x *ContextualizedMetric) ProtoReflect() protoreflect.Message
func (*ContextualizedMetric) Reset ¶
func (x *ContextualizedMetric) Reset()
func (*ContextualizedMetric) String ¶
func (x *ContextualizedMetric) String() string
type GatewayContext ¶
type GatewayContext struct { NetworkId string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` GatewayId string `protobuf:"bytes,2,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"` // contains filtered or unexported fields }
GatewayContext contains context for metrics submitted from gateways.
func (*GatewayContext) Descriptor
deprecated
func (*GatewayContext) Descriptor() ([]byte, []int)
Deprecated: Use GatewayContext.ProtoReflect.Descriptor instead.
func (*GatewayContext) GetGatewayId ¶
func (x *GatewayContext) GetGatewayId() string
func (*GatewayContext) GetNetworkId ¶
func (x *GatewayContext) GetNetworkId() string
func (*GatewayContext) ProtoMessage ¶
func (*GatewayContext) ProtoMessage()
func (*GatewayContext) ProtoReflect ¶
func (x *GatewayContext) ProtoReflect() protoreflect.Message
func (*GatewayContext) Reset ¶
func (x *GatewayContext) Reset()
func (*GatewayContext) String ¶
func (x *GatewayContext) String() string
type MetricsExporterClient ¶
type MetricsExporterClient interface { // Submit metrics to datasinks. Submit(ctx context.Context, in *SubmitMetricsRequest, opts ...grpc.CallOption) (*SubmitMetricsResponse, error) }
MetricsExporterClient is the client API for MetricsExporter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMetricsExporterClient ¶
func NewMetricsExporterClient(cc grpc.ClientConnInterface) MetricsExporterClient
type MetricsExporterServer ¶
type MetricsExporterServer interface { // Submit metrics to datasinks. Submit(context.Context, *SubmitMetricsRequest) (*SubmitMetricsResponse, error) }
MetricsExporterServer is the server API for MetricsExporter service.
type PushedContext ¶
type PushedContext struct { NetworkId string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` // contains filtered or unexported fields }
PushedContext contains context for metrics pushed via the REST API.
func (*PushedContext) Descriptor
deprecated
func (*PushedContext) Descriptor() ([]byte, []int)
Deprecated: Use PushedContext.ProtoReflect.Descriptor instead.
func (*PushedContext) GetNetworkId ¶
func (x *PushedContext) GetNetworkId() string
func (*PushedContext) ProtoMessage ¶
func (*PushedContext) ProtoMessage()
func (*PushedContext) ProtoReflect ¶
func (x *PushedContext) ProtoReflect() protoreflect.Message
func (*PushedContext) Reset ¶
func (x *PushedContext) Reset()
func (*PushedContext) String ¶
func (x *PushedContext) String() string
type SubmitMetricsRequest ¶
type SubmitMetricsRequest struct { Metrics []*ContextualizedMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"` // contains filtered or unexported fields }
func (*SubmitMetricsRequest) Descriptor
deprecated
func (*SubmitMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitMetricsRequest.ProtoReflect.Descriptor instead.
func (*SubmitMetricsRequest) GetMetrics ¶
func (x *SubmitMetricsRequest) GetMetrics() []*ContextualizedMetric
func (*SubmitMetricsRequest) ProtoMessage ¶
func (*SubmitMetricsRequest) ProtoMessage()
func (*SubmitMetricsRequest) ProtoReflect ¶
func (x *SubmitMetricsRequest) ProtoReflect() protoreflect.Message
func (*SubmitMetricsRequest) Reset ¶
func (x *SubmitMetricsRequest) Reset()
func (*SubmitMetricsRequest) String ¶
func (x *SubmitMetricsRequest) String() string
type SubmitMetricsResponse ¶
type SubmitMetricsResponse struct {
// contains filtered or unexported fields
}
func (*SubmitMetricsResponse) Descriptor
deprecated
func (*SubmitMetricsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitMetricsResponse.ProtoReflect.Descriptor instead.
func (*SubmitMetricsResponse) ProtoMessage ¶
func (*SubmitMetricsResponse) ProtoMessage()
func (*SubmitMetricsResponse) ProtoReflect ¶
func (x *SubmitMetricsResponse) ProtoReflect() protoreflect.Message
func (*SubmitMetricsResponse) Reset ¶
func (x *SubmitMetricsResponse) Reset()
func (*SubmitMetricsResponse) String ¶
func (x *SubmitMetricsResponse) String() string
type UnimplementedMetricsExporterServer ¶
type UnimplementedMetricsExporterServer struct { }
UnimplementedMetricsExporterServer can be embedded to have forward compatible implementations.
func (*UnimplementedMetricsExporterServer) Submit ¶
func (*UnimplementedMetricsExporterServer) Submit(context.Context, *SubmitMetricsRequest) (*SubmitMetricsResponse, error)