utilization

Sep 24, 2024

Changes in this version

type Server

+ ResponseMutex sync.RWMutex

May 9, 2024

Changes in this version

+ var AdditionalGrpcServers []AdditionalGrpcServer

+ type AdditionalGrpcServer struct

+ RegisterHandler func(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ RegisterServer func(s grpc.ServiceRegistrar)

type Server

+ IsCached atomic.Bool

+ IsHealthyResult atomic.Bool

+ IsReadyResult atomic.Bool

+ ServeResults atomic.Bool

+ func (s *Server) GetNodeNames() sets.String

+ func (s *Server) IsReady(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

Jan 6, 2023

Changes in this version

+ const FilterExpiredMetricsEnvName

+ type Server struct

+ IsHealthy atomic.Bool

+ IsLeaderElected atomic.Bool

+ ResponseMutext sync.RWMutex

+ Responses map[string]*api.ListMetricsResponse

+ func (c *Server) Collect(ch chan<- prometheus.Metric, metrics map[string]*api.ListMetricsResponse)

+ func (c *Server) GetContainerUsageSummary(metrics map[string]*api.ListMetricsResponse) map[sampler.ContainerKey]*api.ContainerMetrics

+ func (s *Server) CacheMetrics(msg *api.ListMetricsResponse)

+ func (s *Server) Check(ctx context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

+ func (s *Server) ClearMetrics(key string)

+ func (s *Server) GetMetrics() map[string]*api.ListMetricsResponse

+ func (s *Server) IsLeader(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

+ func (s *Server) PushMetrics(req api.MetricsCollector_PushMetricsServer) error

+ func (s *Server) Start(ctx context.Context) error