From ecfae7975b76079e99feec170f8d5da11e3f0561 Mon Sep 17 00:00:00 2001 From: Michael Quigley Date: Mon, 20 Mar 2023 15:05:45 -0400 Subject: [PATCH] probably not an optimal approach for this flux query, but seems to be working (#271) --- controller/limits/influxReader.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/controller/limits/influxReader.go b/controller/limits/influxReader.go index e74d23bf..99e3aca0 100644 --- a/controller/limits/influxReader.go +++ b/controller/limits/influxReader.go @@ -31,6 +31,7 @@ func (r *influxReader) totalRxForAccount(acctId int64, duration time.Duration) ( "|> filter(fn: (r) => r[\"_field\"] == \"bytesRead\")\n" + "|> filter(fn: (r) => r[\"namespace\"] == \"backend\")\n" + fmt.Sprintf("|> filter(fn: (r) => r[\"acctId\"] == \"%d\")\n", acctId) + + "|> set(key: \"share\", value: \"*\")\n" + "|> sum()" return r.runQueryForSum(query) } @@ -42,6 +43,7 @@ func (r *influxReader) totalTxForAccount(acctId int64, duration time.Duration) ( "|> filter(fn: (r) => r[\"_field\"] == \"bytesWritten\")\n" + "|> filter(fn: (r) => r[\"namespace\"] == \"backend\")\n" + fmt.Sprintf("|> filter(fn: (r) => r[\"acctId\"] == \"%d\")\n", acctId) + + "|> set(key: \"share\", value: \"*\")\n" + "|> sum()" return r.runQueryForSum(query) } @@ -53,6 +55,7 @@ func (r *influxReader) totalRxForEnvironment(envId int64, duration time.Duration "|> filter(fn: (r) => r[\"_field\"] == \"bytesRead\")\n" + "|> filter(fn: (r) => r[\"namespace\"] == \"backend\")\n" + fmt.Sprintf("|> filter(fn: (r) => r[\"envId\"] == \"%d\")\n", envId) + + "|> set(key: \"share\", value: \"*\")\n" + "|> sum()" return r.runQueryForSum(query) } @@ -64,6 +67,7 @@ func (r *influxReader) totalTxForEnvironment(envId int64, duration time.Duration "|> filter(fn: (r) => r[\"_field\"] == \"bytesWritten\")\n" + "|> filter(fn: (r) => r[\"namespace\"] == \"backend\")\n" + fmt.Sprintf("|> filter(fn: (r) => r[\"envId\"] == \"%d\")\n", envId) + + "|> set(key: \"share\", value: \"*\")\n" + "|> sum()" return r.runQueryForSum(query) }