extractors

Documentation

Index

• Constants
• func AssertContainsTaggedField(t *testing.T, cadvisorMetric *CAdvisorMetric, ...)
• func AssertContainsTaggedFloat(t *testing.T, cadvisorMetric *CAdvisorMetric, field string, ...)
• func GetStats(info *cinfo.ContainerInfo) *cinfo.ContainerStats
• type CAdvisorMetric
  • func (c *CAdvisorMetric) AddTags(tags map[string]string)
  • func (c *CAdvisorMetric) GetAllTags() 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() *CpuMetricExtractor
  • func (c *CpuMetricExtractor) CleanUp(now time.Time)
  • func (c *CpuMetricExtractor) GetValue(info *cInfo.ContainerInfo, containerType string) []*CAdvisorMetric
  • func (c *CpuMetricExtractor) HasValue(info *cInfo.ContainerInfo) bool
• type DiskIOMetricExtractor
  • func NewDiskIOMetricExtractor() *DiskIOMetricExtractor
  • func (d *DiskIOMetricExtractor) CleanUp(now time.Time)
  • func (d *DiskIOMetricExtractor) GetValue(info *cinfo.ContainerInfo, containerType string) []*CAdvisorMetric
  • func (d *DiskIOMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
• type FileSystemMetricExtractor
  • func NewFileSystemMetricExtractor() *FileSystemMetricExtractor
  • func (f *FileSystemMetricExtractor) CleanUp(now time.Time)
  • func (f *FileSystemMetricExtractor) GetValue(info *cinfo.ContainerInfo, containerType string) []*CAdvisorMetric
  • func (f *FileSystemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
• type MemMetricExtractor
  • func NewMemMetricExtractor() *MemMetricExtractor
  • func (m *MemMetricExtractor) CleanUp(now time.Time)
  • func (m *MemMetricExtractor) GetValue(info *cinfo.ContainerInfo, containerType string) []*CAdvisorMetric
  • func (m *MemMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool
• type MetricExtractor
• type NetMetricExtractor
  • func NewNetMetricExtractor() *NetMetricExtractor
  • func (n *NetMetricExtractor) CleanUp(now time.Time)
  • func (n *NetMetricExtractor) GetValue(info *cinfo.ContainerInfo, containerType string) []*CAdvisorMetric
  • func (n *NetMetricExtractor) HasValue(info *cinfo.ContainerInfo) bool

Constants

const (
	Metrics       = "Metrics"
	Dimensions    = "Dimensions"
	CleanInterval = 5 * time.Minute
)

const (
	CurInfo = `` /* 5043-byte string literal not displayed */

	PreInfo = `` /* 5039-byte string literal not displayed */

)

Functions

func AssertContainsTaggedField

func AssertContainsTaggedField(
	t *testing.T,
	cadvisorMetric *CAdvisorMetric,
	expectedFields map[string]interface{},
	expectedTags map[string]string,
)

func AssertContainsTaggedFloat

func AssertContainsTaggedFloat(
	t *testing.T,
	cadvisorMetric *CAdvisorMetric,
	field string,
	expectedValue float64,
	delta float64,
)

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) GetAllTags

func (c *CAdvisorMetric) GetAllTags() 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() *CpuMetricExtractor

func (*CpuMetricExtractor) CleanUp

func (c *CpuMetricExtractor) CleanUp(now time.Time)

func (*CpuMetricExtractor) GetValue

func (c *CpuMetricExtractor) GetValue(info *cInfo.ContainerInfo, 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() *DiskIOMetricExtractor

func (*DiskIOMetricExtractor) CleanUp

func (d *DiskIOMetricExtractor) CleanUp(now time.Time)

func (*DiskIOMetricExtractor) GetValue

func (d *DiskIOMetricExtractor) GetValue(info *cinfo.ContainerInfo, 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() *FileSystemMetricExtractor

func (*FileSystemMetricExtractor) CleanUp

func (f *FileSystemMetricExtractor) CleanUp(now time.Time)

func (*FileSystemMetricExtractor) GetValue

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

func (*FileSystemMetricExtractor) HasValue

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

TODO(pingleig): it is always false for container using containerd https://github.com/aws/amazon-cloudwatch-agent/issues/192

type MemMetricExtractor

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

func NewMemMetricExtractor

func NewMemMetricExtractor() *MemMetricExtractor

func (*MemMetricExtractor) CleanUp

func (m *MemMetricExtractor) CleanUp(now time.Time)

func (*MemMetricExtractor) GetValue

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

func (*MemMetricExtractor) HasValue

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

type MetricExtractor

type MetricExtractor interface {
	HasValue(*cinfo.ContainerInfo) bool
	// GetValue normally applies to the following types:
	// containerinsightscommon.TypeContainer
	// containerinsightscommon.TypePod
	// containerinsightscommon.TypeNode
	// and ignores:
	// containerinsightscommon.TypeInfraContainer
	// The only exception is NetMetricExtractor because pod network metrics comes from infra container (i.e. pause).
	// See https://www.ianlewis.org/en/almighty-pause-container
	GetValue(info *cinfo.ContainerInfo, containerType string) []*CAdvisorMetric
	CleanUp(time.Time)
}

type NetMetricExtractor

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

func NewNetMetricExtractor

func NewNetMetricExtractor() *NetMetricExtractor

func (*NetMetricExtractor) CleanUp

func (n *NetMetricExtractor) CleanUp(now time.Time)

func (*NetMetricExtractor) GetValue

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

func (*NetMetricExtractor) HasValue

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