containermetrics

type CPUInfo struct {
	TimeSpentInCPU                      time.Duration
	TimeOfSample                        time.Time
	AbsoluteCPUEntitlementInNanoseconds uint64
}

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

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 DefaultMetricsProcessor struct{}

type MetricsProcessor interface {
	ProcessAndSend(logger lager.Logger, metronClient loggingclient.IngressClient, metricsConfig executor.MetricsConfig, containerMetrics executor.ContainerMetrics, previousInfo *CPUInfo, now time.Time) (CPUInfo, *CachedContainerMetrics)
}

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

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

type StatsReporter struct {
	CPUInfos map[string]*CPUInfo
	// contains filtered or unexported fields
}