metricDataDispatcher

func LoadAverages ¶

func LoadAverages(
	job *schema.Job,
	metrics []string,
	data [][]schema.Float,
	ctx context.Context,
) error

Used for the jobsFootprint GraphQL-Query. TODO: Rename/Generalize.

func LoadData ¶

func LoadData(job *schema.Job,
	metrics []string,
	scopes []schema.MetricScope,
	ctx context.Context,
	resolution int,
) (schema.JobData, error)

Fetches the metric data for a job.

func LoadJobStats ¶ added in v1.4.4

func LoadJobStats(
	job *schema.Job,
	metrics []string,
	ctx context.Context,
) (map[string]schema.MetricStatistics, error)

Used for polar plots in frontend: Aggregates statistics for all nodes to single values for job per metric.

func LoadNodeData ¶

func LoadNodeData(
	cluster string,
	metrics, nodes []string,
	scopes []schema.MetricScope,
	from, to time.Time,
	ctx context.Context,
) (map[string]map[string][]*schema.JobMetric, error)

Used for the classic node/system view. Returns a map of nodes to a map of metrics.

func LoadNodeListData ¶ added in v1.4.3

func LoadNodeListData(
	cluster, subCluster, nodeFilter string,
	metrics []string,
	scopes []schema.MetricScope,
	resolution int,
	from, to time.Time,
	page *model.PageRequest,
	ctx context.Context,
) (map[string]schema.JobData, int, bool, error)

func LoadScopedJobStats ¶ added in v1.4.4

func LoadScopedJobStats(
	job *schema.Job,
	metrics []string,
	scopes []schema.MetricScope,
	ctx context.Context,
) (schema.ScopedJobStats, error)

Used for statsTable in frontend: Return scoped statistics by metric.