Documentation
¶
Index ¶
- type MetricsControllerServer
- func (srv *MetricsControllerServer) Collect(ctx context.Context, in *protos.MetricsContainer) (*protos.Void, error)
- func (srv *MetricsControllerServer) ConsumeCloudMetrics(inputChan chan *prom_proto.MetricFamily, hostName string)
- func (srv *MetricsControllerServer) Push(ctx context.Context, in *protos.PushedMetricsContainer) (*protos.Void, error)
- func (srv *MetricsControllerServer) RegisterExporter(e exporters.Exporter) []exporters.Exporter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetricsControllerServer ¶
type MetricsControllerServer struct {
// contains filtered or unexported fields
}
MetricsControllerServer implements a handler to the gRPC server run by the Metrics Controller. It can register instances of the Exporter interface for writing to storage
func NewMetricsControllerServer ¶
func NewMetricsControllerServer() *MetricsControllerServer
func (*MetricsControllerServer) Collect ¶
func (srv *MetricsControllerServer) Collect(ctx context.Context, in *protos.MetricsContainer) (*protos.Void, error)
func (*MetricsControllerServer) ConsumeCloudMetrics ¶
func (srv *MetricsControllerServer) ConsumeCloudMetrics(inputChan chan *prom_proto.MetricFamily, hostName string)
ConsumeCloudMetrics pulls metrics off the given input channel and sends them to all exporters after some preprocessing. Returns only when inputChan closed, which should never happen.
func (*MetricsControllerServer) Push ¶
func (srv *MetricsControllerServer) Push(ctx context.Context, in *protos.PushedMetricsContainer) (*protos.Void, error)
func (*MetricsControllerServer) RegisterExporter ¶
func (srv *MetricsControllerServer) RegisterExporter(e exporters.Exporter) []exporters.Exporter
Source Files
Click to show internal directories.
Click to hide internal directories.