metrics

type Provider interface {
	GetWorkersMetrics(context.Context) ([]*WorkerUsage, error)
	GetHistoryMetrics(context.Context) ([]*WorkerUsage, error)
	LoadHistoryMetrics(context.Context, func(*WorkerUsage)) error
}

type WorkerUsage struct {
	Namespace    string
	WorkloadName string
	WorkerName   string
	TflopsUsage  float64
	VramUsage    uint64
	Timestamp    time.Time
}

type WorkerUsageAggregator struct {
	TflopsHistogram   vpa.Histogram
	VramHistogram     vpa.Histogram
	FirstSampleStart  time.Time
	LastSampleStart   time.Time
	TotalSamplesCount int
}

type WorkerUsageSampler struct {
	LastTflopsSampleTime time.Time
	VramPeak             uint64
	LastVramSampleTime   time.Time
	VramWindowEnd        time.Time
}