extractors

Documentation

Index

• Constants
• func GetStats(info *cinfo.ContainerInfo) *cinfo.ContainerStats
• type CAdvisorMetric
  • func (c *CAdvisorMetric) AddTags(tags map[string]string)
  • func (c *CAdvisorMetric) GetFields() map[string]interface{}
  • func (c *CAdvisorMetric) GetMetricType() string
  • func (c *CAdvisorMetric) GetTags() map[string]string
  • func (c *CAdvisorMetric) Merge(src *CAdvisorMetric)
• type CpuMetricExtractor
  • func NewCpuMetricExtractor(logger *zap.Logger) *CpuMetricExtractor
  • func (c *CpuMetricExtractor) GetValue(info *cInfo.ContainerInfo, mInfo MachineInfoProvider, containerType string) []*CAdvisorMetric
  • func (c *CpuMetricExtractor) HasValue(info *cInfo.ContainerInfo) bool
• type DiskIOMetricExtractor
  • func NewDiskIOMetricExtractor(logger *zap.Logger) *DiskIOMetricExtractor
  • func (d *DiskIOMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ MachineInfoProvider, containerType string) []*CAdvisorMetric
  • func (d *DiskIOMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
• type FileSystemMetricExtractor
  • func NewFileSystemMetricExtractor(logger *zap.Logger) *FileSystemMetricExtractor
  • func (f *FileSystemMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ MachineInfoProvider, containerType string) []*CAdvisorMetric
  • func (f *FileSystemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
• type MachineInfoProvider
• type MemMetricExtractor
  • func NewMemMetricExtractor(logger *zap.Logger) *MemMetricExtractor
  • func (m *MemMetricExtractor) GetValue(info *cinfo.ContainerInfo, mInfo MachineInfoProvider, containerType string) []*CAdvisorMetric
  • func (m *MemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
• type MetricExtractor
• type NetMetricExtractor
  • func NewNetMetricExtractor(logger *zap.Logger) *NetMetricExtractor
  • func (n *NetMetricExtractor) GetValue(info *cinfo.ContainerInfo, _ MachineInfoProvider, containerType string) []*CAdvisorMetric
  • func (n *NetMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool

Constants

const (
	Metrics    = "Metrics"
	Dimensions = "Dimensions"
)

Functions

func GetStats

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

Types

type CAdvisorMetric

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

func (*CAdvisorMetric) AddTags

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

func (*CAdvisorMetric) GetFields

func (c *CAdvisorMetric) GetFields() map[string]interface{}

func (*CAdvisorMetric) GetMetricType

func (c *CAdvisorMetric) GetMetricType() string

func (*CAdvisorMetric) GetTags

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

func (*CAdvisorMetric) Merge

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

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 MachineInfoProvider, containerType string) []*CAdvisorMetric

func (*CpuMetricExtractor) HasValue

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

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, _ MachineInfoProvider, containerType string) []*CAdvisorMetric

func (*DiskIOMetricExtractor) HasValue

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

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, _ MachineInfoProvider, containerType string) []*CAdvisorMetric

func (*FileSystemMetricExtractor) HasValue

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

type MachineInfoProvider

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

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 MachineInfoProvider, containerType string) []*CAdvisorMetric

func (*MemMetricExtractor) HasValue

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

type MetricExtractor

type MetricExtractor interface {
	HasValue(*cinfo.ContainerInfo) bool
	GetValue(*cinfo.ContainerInfo, MachineInfoProvider, string) []*CAdvisorMetric
}

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, _ MachineInfoProvider, containerType string) []*CAdvisorMetric

func (*NetMetricExtractor) HasValue

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