sampler

Sep 24, 2024

Changes in this version

type ContainerMetricType

+ const CPUThrottlingMetricTypeV1

+ const MemoryCurrentMetricsTypeV2

+ const MemoryOOMKillMetricTypeV1

+ const MemoryOOMMetricType

May 9, 2024

Changes in this version

type ContainerKey

+ ContainerName string

+ NamespaceName string

+ PodName string

type Server

+ CTX context.Context

+ HostName string

+ func (s *Server) RegisterCollectors(ctx context.Context, req *api.RegisterCollectorsRequest) (*api.RegisterCollectorsResponse, error)

Jan 6, 2023

Changes in this version

+ type ContainerCPUThrottlingMetrics struct

+ ThrottledNanoSec uint64

+ ThrottledPeriods uint64

+ Time time.Time

+ TotalPeriods uint64

+ type ContainerKey struct

+ ContainerID string

+ PodUID string

+ type ContainerMetricType string

+ const CPUThrottlingMetricType

+ const CPUUsageMetricType

+ const MemoryOMMMetricType

+ const MemoryOOMKillMetricType

+ const MemoryUsageMetricType

+ type Float32Slice []float32

+ func (x Float32Slice) Len() int

+ func (x Float32Slice) Less(i, j int) bool

+ func (x Float32Slice) Swap(i, j int)

+ type Int64Slice []int64

+ func (x Int64Slice) Len() int

+ func (x Int64Slice) Less(i, j int) bool

+ func (x Int64Slice) Swap(i, j int)

+ type NodeAggregatedMetricsSlice []*api.NodeAggregatedMetrics

+ func (x NodeAggregatedMetricsSlice) Len() int

+ func (x NodeAggregatedMetricsSlice) Less(i, j int) bool

+ func (x NodeAggregatedMetricsSlice) Swap(i, j int)

+ type Server struct

+ FS fs.FS

+ PushErrorMsg atomic.Value

+ PushHealthy atomic.Bool

+ SortResults bool

+ TimeFunc func(string) time.Time

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

+ func (s *Server) ListMetrics(context.Context, *api.ListMetricsRequest) (*api.ListMetricsResponse, error)

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

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

+ func (s *Server) Stop()