extractors

Documentation

Index

• func GetStats(info *cinfo.ContainerInfo) *cinfo.ContainerStats
• type CAdvisorMetric
  • func MergeMetrics(metrics []*CAdvisorMetric) []*CAdvisorMetric
  • func (c *CAdvisorMetric) AddField(key string, val any)
  • func (c *CAdvisorMetric) AddTag(key, val string)
  • func (c *CAdvisorMetric) AddTags(tags map[string]string)
  • func (c *CAdvisorMetric) GetField(key string) any
  • func (c *CAdvisorMetric) GetFields() map[string]any
  • func (c *CAdvisorMetric) GetMetricType() string
  • func (c *CAdvisorMetric) GetTag(key string) string
  • func (c *CAdvisorMetric) GetTags() map[string]string
  • func (c *CAdvisorMetric) HasField(key string) bool
  • func (c *CAdvisorMetric) HasTag(key string) bool
  • func (c *CAdvisorMetric) Merge(src *CAdvisorMetric)
  • func (c *CAdvisorMetric) RemoveTag(key string)
• type CPUMemInfoProvider
• type CPUMetricExtractor
  • func NewCPUMetricExtractor(logger *zap.Logger) *CPUMetricExtractor
  • func (c *CPUMetricExtractor) GetValue(info *cInfo.ContainerInfo, mInfo CPUMemInfoProvider, containerType string) []*CAdvisorMetric
  • func (c *CPUMetricExtractor) HasValue(info *cInfo.ContainerInfo) bool
  • func (c *CPUMetricExtractor) Shutdown() error
• type DiskIOMetricExtractor
  • func NewDiskIOMetricExtractor(logger *zap.Logger) *DiskIOMetricExtractor
  • func (d *DiskIOMetricExtractor) GetValue(info *cInfo.ContainerInfo, _ CPUMemInfoProvider, containerType string) []*CAdvisorMetric
  • func (d *DiskIOMetricExtractor) HasValue(info *cInfo.ContainerInfo) bool
  • func (d *DiskIOMetricExtractor) Shutdown() error
• type FileSystemMetricExtractor
  • func NewFileSystemMetricExtractor(logger *zap.Logger) *FileSystemMetricExtractor
  • func (f *FileSystemMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ CPUMemInfoProvider, containerType string) []*CAdvisorMetric
  • func (f *FileSystemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
  • func (f *FileSystemMetricExtractor) Shutdown() error
• type MemMetricExtractor
  • func NewMemMetricExtractor(logger *zap.Logger) *MemMetricExtractor
  • func (m *MemMetricExtractor) GetValue(info *cinfo.ContainerInfo, mInfo CPUMemInfoProvider, containerType string) []*CAdvisorMetric
  • func (m *MemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
  • func (m *MemMetricExtractor) Shutdown() error
• type MetricExtractor
• type NetMetricExtractor
  • func NewNetMetricExtractor(logger *zap.Logger) *NetMetricExtractor
  • func (n *NetMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ CPUMemInfoProvider, containerType string) []*CAdvisorMetric
  • func (n *NetMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
  • func (n *NetMetricExtractor) Shutdown() error

Functions

func GetStats

func GetStats(info *cinfo.ContainerInfo) *cinfo.ContainerStats

Types

type CAdvisorMetric

type CAdvisorMetric struct {
	// contains filtered or unexported fields
}

func MergeMetrics

func MergeMetrics(metrics []*CAdvisorMetric) []*CAdvisorMetric

MergeMetrics merges an array of cadvisor metrics based on common metric keys

func (*CAdvisorMetric) AddField

func (c *CAdvisorMetric) AddField(key string, val any)

func (*CAdvisorMetric) AddTag

func (c *CAdvisorMetric) AddTag(key, val string)

func (*CAdvisorMetric) AddTags

func (c *CAdvisorMetric) AddTags(tags map[string]string)

func (*CAdvisorMetric) GetField

func (c *CAdvisorMetric) GetField(key string) any

func (*CAdvisorMetric) GetFields

func (c *CAdvisorMetric) GetFields() map[string]any

func (*CAdvisorMetric) GetMetricType

func (c *CAdvisorMetric) GetMetricType() string

func (*CAdvisorMetric) GetTag

func (c *CAdvisorMetric) GetTag(key string) string

func (*CAdvisorMetric) GetTags

func (c *CAdvisorMetric) GetTags() map[string]string

func (*CAdvisorMetric) HasField

func (c *CAdvisorMetric) HasField(key string) bool

func (*CAdvisorMetric) HasTag

func (c *CAdvisorMetric) HasTag(key string) bool

func (*CAdvisorMetric) Merge

func (c *CAdvisorMetric) Merge(src *CAdvisorMetric)

func (*CAdvisorMetric) RemoveTag

func (c *CAdvisorMetric) RemoveTag(key string)

type CPUMemInfoProvider

type CPUMemInfoProvider interface {
	GetNumCores() int64
	GetMemoryCapacity() int64
}

type CPUMetricExtractor

type CPUMetricExtractor struct {
	// contains filtered or unexported fields
}

func NewCPUMetricExtractor

func NewCPUMetricExtractor(logger *zap.Logger) *CPUMetricExtractor

func (*CPUMetricExtractor) GetValue

func (c *CPUMetricExtractor) GetValue(info *cInfo.ContainerInfo, mInfo CPUMemInfoProvider, containerType string) []*CAdvisorMetric

func (*CPUMetricExtractor) HasValue

func (c *CPUMetricExtractor) HasValue(info *cInfo.ContainerInfo) bool

func (*CPUMetricExtractor) Shutdown

func (c *CPUMetricExtractor) Shutdown() error

type DiskIOMetricExtractor

type DiskIOMetricExtractor struct {
	// contains filtered or unexported fields
}

func NewDiskIOMetricExtractor

func NewDiskIOMetricExtractor(logger *zap.Logger) *DiskIOMetricExtractor

func (*DiskIOMetricExtractor) GetValue

func (d *DiskIOMetricExtractor) GetValue(info *cInfo.ContainerInfo, _ CPUMemInfoProvider, containerType string) []*CAdvisorMetric

func (*DiskIOMetricExtractor) HasValue

func (d *DiskIOMetricExtractor) HasValue(info *cInfo.ContainerInfo) bool

func (*DiskIOMetricExtractor) Shutdown

func (d *DiskIOMetricExtractor) Shutdown() error

type FileSystemMetricExtractor

type FileSystemMetricExtractor struct {
	// contains filtered or unexported fields
}

func NewFileSystemMetricExtractor

func NewFileSystemMetricExtractor(logger *zap.Logger) *FileSystemMetricExtractor

func (*FileSystemMetricExtractor) GetValue

func (f *FileSystemMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ CPUMemInfoProvider, containerType string) []*CAdvisorMetric

func (*FileSystemMetricExtractor) HasValue

func (f *FileSystemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool

func (*FileSystemMetricExtractor) Shutdown

func (f *FileSystemMetricExtractor) Shutdown() error

type MemMetricExtractor

type MemMetricExtractor struct {
	// contains filtered or unexported fields
}

func NewMemMetricExtractor

func NewMemMetricExtractor(logger *zap.Logger) *MemMetricExtractor

func (*MemMetricExtractor) GetValue

func (m *MemMetricExtractor) GetValue(info *cinfo.ContainerInfo, mInfo CPUMemInfoProvider, containerType string) []*CAdvisorMetric

func (*MemMetricExtractor) HasValue

func (m *MemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool

func (*MemMetricExtractor) Shutdown

func (m *MemMetricExtractor) Shutdown() error

type MetricExtractor

type MetricExtractor interface {
	HasValue(*cinfo.ContainerInfo) bool
	GetValue(info *cinfo.ContainerInfo, mInfo CPUMemInfoProvider, containerType string) []*CAdvisorMetric
	Shutdown() error
}

type NetMetricExtractor

type NetMetricExtractor struct {
	// contains filtered or unexported fields
}

func NewNetMetricExtractor

func NewNetMetricExtractor(logger *zap.Logger) *NetMetricExtractor

func (*NetMetricExtractor) GetValue

func (n *NetMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ CPUMemInfoProvider, containerType string) []*CAdvisorMetric

func (*NetMetricExtractor) HasValue

func (n *NetMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool

func (*NetMetricExtractor) Shutdown

func (n *NetMetricExtractor) Shutdown() error