metricdata

Apr 24, 2025

Changes in this version

type CCMetricStore

+ func (ccms *CCMetricStore) LoadScopedStats(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.ScopedJobStats, error)

type InfluxDBv2DataRepository

+ func (idb *InfluxDBv2DataRepository) LoadScopedStats(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.ScopedJobStats, error)

type MetricDataRepository

+ LoadScopedStats func(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.ScopedJobStats, error)

type PrometheusDataRepository

+ func (pdb *PrometheusDataRepository) LoadScopedStats(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.ScopedJobStats, error)

type TestMetricDataRepository

+ func (tmdr *TestMetricDataRepository) LoadScopedStats(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.ScopedJobStats, error)

Mar 14, 2025

Changes in this version

type CCMetricStore

+ func (ccms *CCMetricStore) LoadNodeListData(cluster, subCluster, nodeFilter string, metrics []string, ...) (map[string]schema.JobData, int, bool, error)

type InfluxDBv2DataRepository

+ func (idb *InfluxDBv2DataRepository) LoadNodeListData(cluster, subCluster, nodeFilter string, metrics []string, ...) (map[string]schema.JobData, int, bool, error)

type MetricDataRepository

+ LoadNodeListData func(cluster, subCluster, nodeFilter string, metrics []string, ...) (map[string]schema.JobData, int, bool, error)

type PrometheusDataRepository

+ func (pdb *PrometheusDataRepository) LoadNodeListData(cluster, subCluster, nodeFilter string, metrics []string, ...) (map[string]schema.JobData, int, bool, error)

type TestMetricDataRepository

+ func (tmdr *TestMetricDataRepository) LoadNodeListData(cluster, subCluster, nodeFilter string, metrics []string, ...) (map[string]schema.JobData, int, bool, error)

Dec 5, 2024

Changes in this version

+ func DeepCopy(jd_temp schema.JobData) schema.JobData

type ApiMetricData

+ Resolution int

type ApiQuery

+ Resolution int

type MetricDataRepository

+ func GetMetricDataRepo(cluster string) (MetricDataRepository, error)

Jul 3, 2023

Changes in this version

+ var TestLoadDataCallback func(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error) = func(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ func ArchiveJob(job *schema.Job, ctx context.Context) (*schema.JobMeta, error)

+ func Init(disableArchive bool) error

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

+ func LoadData(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ func LoadNodeData(cluster string, metrics, nodes []string, scopes []schema.MetricScope, ...) (map[string]map[string][]*schema.JobMetric, error)

+ func MinMaxMean(data []schema.Float) (float64, float64, float64)

+ type ApiMetricData struct

+ Avg schema.Float

+ Data []schema.Float

+ Error *string

+ From int64

+ Max schema.Float

+ Min schema.Float

+ To int64

+ type ApiQuery struct

+ Aggregate bool

+ Hostname string

+ Metric string

+ SubType *string

+ SubTypeIds []string

+ Type *string

+ TypeIds []string

+ type ApiQueryRequest struct

+ Cluster string

+ ForAllNodes []string

+ From int64

+ Queries []ApiQuery

+ To int64

+ WithData bool

+ WithStats bool

+ type ApiQueryResponse struct

+ Queries []ApiQuery

+ Results [][]ApiMetricData

+ type CCMetricStore struct

+ func (ccms *CCMetricStore) Init(rawConfig json.RawMessage) error

+ func (ccms *CCMetricStore) LoadData(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ func (ccms *CCMetricStore) LoadNodeData(cluster string, metrics, nodes []string, scopes []schema.MetricScope, ...) (map[string]map[string][]*schema.JobMetric, error)

+ func (ccms *CCMetricStore) LoadStats(job *schema.Job, metrics []string, ctx context.Context) (map[string]map[string]schema.MetricStatistics, error)

+ type CCMetricStoreConfig struct

+ Kind string

+ Renamings map[string]string

+ Token string

+ Url string

+ type InfluxDBv2DataRepository struct

+ func (idb *InfluxDBv2DataRepository) Init(rawConfig json.RawMessage) error

+ func (idb *InfluxDBv2DataRepository) LoadData(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ func (idb *InfluxDBv2DataRepository) LoadNodeData(cluster string, metrics, nodes []string, scopes []schema.MetricScope, ...) (map[string]map[string][]*schema.JobMetric, error)

+ func (idb *InfluxDBv2DataRepository) LoadStats(job *schema.Job, metrics []string, ctx context.Context) (map[string]map[string]schema.MetricStatistics, error)

+ type InfluxDBv2DataRepositoryConfig struct

+ Bucket string

+ Org string

+ SkipTls bool

+ Token string

+ Url string

+ type MetricDataRepository interface

+ Init func(rawConfig json.RawMessage) error

+ LoadData func(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ LoadNodeData func(cluster string, metrics, nodes []string, scopes []schema.MetricScope, ...) (map[string]map[string][]*schema.JobMetric, error)

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

+ type PromQLArgs struct

+ Nodes string

+ type PrometheusDataRepository struct

+ func (pdb *PrometheusDataRepository) FormatQuery(metric string, scope schema.MetricScope, nodes []string, cluster string) (string, error)

+ func (pdb *PrometheusDataRepository) Init(rawConfig json.RawMessage) error

+ func (pdb *PrometheusDataRepository) LoadData(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ func (pdb *PrometheusDataRepository) LoadNodeData(cluster string, metrics, nodes []string, scopes []schema.MetricScope, ...) (map[string]map[string][]*schema.JobMetric, error)

+ func (pdb *PrometheusDataRepository) LoadStats(job *schema.Job, metrics []string, ctx context.Context) (map[string]map[string]schema.MetricStatistics, error)

+ func (pdb *PrometheusDataRepository) RowToSeries(from time.Time, step int64, steps int64, row *promm.SampleStream) schema.Series

+ type PrometheusDataRepositoryConfig struct

+ Suffix string

+ Templates map[string]string

+ Url string

+ Username string

+ type TestMetricDataRepository struct

+ func (tmdr *TestMetricDataRepository) Init(_ json.RawMessage) error

+ func (tmdr *TestMetricDataRepository) LoadData(job *schema.Job, metrics []string, scopes []schema.MetricScope, ...) (schema.JobData, error)

+ func (tmdr *TestMetricDataRepository) LoadNodeData(cluster string, metrics, nodes []string, scopes []schema.MetricScope, ...) (map[string]map[string][]*schema.JobMetric, error)

+ func (tmdr *TestMetricDataRepository) LoadStats(job *schema.Job, metrics []string, ctx context.Context) (map[string]map[string]schema.MetricStatistics, error)

+ type Trie map[rune]Trie