Versions in this module Expand all Collapse all v1 v1.4.2 Dec 19, 2024 v1.4.1 Dec 10, 2024 v1.4.0 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) v1.3.1 Jun 22, 2024 v1.3.0 Apr 15, 2024 v1.2.2 Sep 15, 2023 v1.2.1 Sep 7, 2023 v1.2.0 Sep 5, 2023 v1.1.0 Jul 20, 2023 v1.0.0 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 v1.0.0-rc.1 Jun 15, 2023
Go to main page