ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2024-11-14 02:37:25 +01:00
Code Issues Packages Releases Activity

Test Commit on Github Error

Browse Source
This commit is contained in:
Christoph Kluge 2022-03-17 15:56:45 +01:00
parent 25abd70f7c
commit 3e0de24307
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
metricdata/influxdb-v2.go
View File

@ -24,7 +24,7 @@ type InfluxDBv2DataRepository struct {
func (idb *InfluxDBv2DataRepository) Init(url string, token string, renamings map[string]string) error { func (idb *InfluxDBv2DataRepository) Init(url string, token string, renamings map[string]string) error {
idb.client = influxdb2.NewClientWithOptions(url, token, influxdb2.DefaultOptions().SetTLSConfig(&tls.Config {InsecureSkipVerify: true,} )) idb.client = influxdb2.NewClientWithOptions(url, token, influxdb2.DefaultOptions().SetTLSConfig(&tls.Config {InsecureSkipVerify: true,} ))
idb.queryClient = idb.client.QueryAPI("ClusterCockpit") // Influxdb Org here: Hardcoded for now idb.queryClient = idb.client.QueryAPI("ClusterCockpit") // TODO: Make configurable
return nil return nil
} }
@ -41,7 +41,7 @@ func (idb *InfluxDBv2DataRepository) LoadData(job *schema.Job, metrics []string,
// Set Bucket & Prepare Measurement // Set Bucket & Prepare Measurement
if (job.Cluster == "woody" || job.Cluster == "emmy" || job.Cluster == "meggie") { if (job.Cluster == "woody" || job.Cluster == "emmy" || job.Cluster == "meggie") {
idb.bucket = "ClusterCockpit/data" // Temporary: Old Line Protocol for old cluster idb.bucket = "ClusterCockpit/data" // Temporary: Old Line Protocol for old cluster, TODO: Make configurable
idb.measurement = "data" // Temporary: Old Line Protocol for old cluster idb.measurement = "data" // Temporary: Old Line Protocol for old cluster
} else { } else {
// idb.bucket = job.Cluster // New: Bucket per Cluster // idb.bucket = job.Cluster // New: Bucket per Cluster