containermetrics

Documentation

Index

• type CPUSpikeReporter
  • func NewCPUSpikeReporter(metronClient loggingclient.IngressClient) *CPUSpikeReporter
  • func (reporter *CPUSpikeReporter) Report(logger lager.Logger, containers []executor.Container, ...) error
• type CachedContainerMetrics
• type MetricsReporter
• type ReportersRunner
  • func NewReportersRunner(logger lager.Logger, interval time.Duration, clock clock.Clock, ...) *ReportersRunner
  • func (reporterRunner *ReportersRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type StatsReporter
  • func NewStatsReporter(metronClient loggingclient.IngressClient, enableContainerProxy bool, ...) *StatsReporter
  • func (reporter *StatsReporter) Metrics() map[string]*CachedContainerMetrics
  • func (reporter *StatsReporter) Report(logger lager.Logger, containers []executor.Container, ...) error

Types

type CPUSpikeReporter

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

func NewCPUSpikeReporter

func NewCPUSpikeReporter(metronClient loggingclient.IngressClient) *CPUSpikeReporter

func (*CPUSpikeReporter) Report

func (reporter *CPUSpikeReporter) Report(logger lager.Logger, containers []executor.Container, metrics map[string]executor.Metrics, timeStamp time.Time) error

type CachedContainerMetrics

type CachedContainerMetrics struct {
	MetricGUID       string  `json:"metric_guid"`
	CPUUsageFraction float64 `json:"cpu_usage_fraction"`
	DiskUsageBytes   uint64  `json:"disk_usage_bytes"`
	DiskQuotaBytes   uint64  `json:"disk_quota_bytes"`
	MemoryUsageBytes uint64  `json:"memory_usage_bytes"`
	MemoryQuotaBytes uint64  `json:"memory_quota_bytes"`
	RxBytes          *uint64 `json:"rx_bytes,omitempty"`
	TxBytes          *uint64 `json:"tx_bytes,omitempty"`
}

type MetricsReporter

type MetricsReporter interface {
	Report(logger lager.Logger, containers []executor.Container, metrics map[string]executor.Metrics, timeStamp time.Time) error
}

type ReportersRunner

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

func NewReportersRunner

func NewReportersRunner(logger lager.Logger,
	interval time.Duration,
	clock clock.Clock,
	executorClient executor.Client,
	metricsReporters ...MetricsReporter,
) *ReportersRunner

func (*ReportersRunner) Run

func (reporterRunner *ReportersRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type StatsReporter

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

func NewStatsReporter

func NewStatsReporter(metronClient loggingclient.IngressClient, enableContainerProxy bool, proxyMemoryAllocation float64, metricsCache *atomic.Value) *StatsReporter

func (*StatsReporter) Metrics

func (reporter *StatsReporter) Metrics() map[string]*CachedContainerMetrics

func (*StatsReporter) Report

func (reporter *StatsReporter) Report(logger lager.Logger, containers []executor.Container, metrics map[string]executor.Metrics, timeStamp time.Time) error