servicers

Documentation

Index

• type MetricsControllerServer
  • func NewMetricsControllerServer() *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

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