containermetrics

package

v0.1442.0 Latest Latest Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 8 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudfoundry/executor

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CPUSpikeReporter ¶ added in v0.1442.0

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

func NewCPUSpikeReporter ¶ added in v0.1442.0

func NewCPUSpikeReporter(metronClient loggingclient.IngressClient) *CPUSpikeReporter

func (*CPUSpikeReporter) Report ¶ added in v0.1442.0

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

type CachedContainerMetrics ¶ added in v0.1442.0

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 ¶ added in v0.1442.0

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

type ReportersRunner ¶ added in v0.1442.0

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

func NewReportersRunner ¶ added in v0.1442.0

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

func (*ReportersRunner) Run ¶ added in v0.1442.0

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 ¶ added in v0.1442.0

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

func (*StatsReporter) Report ¶ added in v0.1442.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL