server

Documentation

Index

• Variables
• func MetricsToPB(metrics map[string]*types.ClusterMetric) *pb.GetMetricsResponse
• func NewGRPCServer(s *Server) *grpc.Server
• type MetricConfig
• type Server
  • func NewServer(listenAddr, promServer, cfgFile string) *Server
  • func (s *Server) GetMetrics(ctx context.Context, req *pb.GetMetricsRequest) (*pb.GetMetricsResponse, error)
  • func (s *Server) Start() error
  • func (s *Server) Watch(req *pb.WatchRequest, srv pb.MetricsService_WatchServer) error

Variables

var (
	ConfigCheckedAt time.Time
)

Functions

func MetricsToPB

func MetricsToPB(metrics map[string]*types.ClusterMetric) *pb.GetMetricsResponse

func NewGRPCServer

func NewGRPCServer(s *Server) *grpc.Server

Types

type MetricConfig

type MetricConfig struct {
	Name         string  `yaml:"name"`
	DeviceLabel  string  `yaml:"device_label"`
	DevicePrefix string  `yaml:"device_prefix"`
	QueryString  string  `yaml:"query_string"`
	Scale        float64 `yaml:"scale"`
}

type Server

type Server struct {
	ListenAddr       string
	PrometheusServer string
	ConfigFile       string
	// contains filtered or unexported fields
}

func NewServer

func NewServer(listenAddr, promServer, cfgFile string) *Server

func (*Server) GetMetrics

func (s *Server) GetMetrics(ctx context.Context, req *pb.GetMetricsRequest) (*pb.GetMetricsResponse, error)

func (*Server) Start

func (s *Server) Start() error

func (*Server) Watch

func (s *Server) Watch(req *pb.WatchRequest, srv pb.MetricsService_WatchServer) error