extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-08-15 02:22:32 +02:00
Code Issues Packages Projects Releases Wiki Activity

more services -> shares (#144)

Browse Source
This commit is contained in:
Michael Quigley
2023-01-04 14:21:23 -05:00
parent fe89551bfb
commit 74b9786a61
23 changed files with 112 additions and 112 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
controller/sparkData.go
View File

@ -6,7 +6,7 @@ import (
"github.com/openziti-test-kitchen/zrok/controller/store"
)
func sparkDataForServices(shrs []*store.Share) (map[string][]int64, error) {
func sparkDataForShares(shrs []*store.Share) (map[string][]int64, error) {
out := make(map[string][]int64)
if len(shrs) > 0 {
@ -37,20 +37,20 @@ func sparkDataForServices(shrs []*store.Share) (map[string][]int64, error) {
}
func sparkFluxQuery(shrs []*store.Share) string {
svcFilter := "|> filter(fn: (r) =>"
shrFilter := "|> filter(fn: (r) =>"
for i, shr := range shrs {
if i > 0 {
svcFilter += " or"
shrFilter += " or"
}
svcFilter += fmt.Sprintf(" r[\"share\"] == \"%v\"", shr.Token)
shrFilter += fmt.Sprintf(" r[\"share\"] == \"%v\"", shr.Token)
}
svcFilter += ")"
shrFilter += ")"
query := "read = from(bucket: \"zrok\")" +
"|> range(start: -5m)" +
"|> filter(fn: (r) => r[\"_measurement\"] == \"xfer\")" +
"|> filter(fn: (r) => r[\"_field\"] == \"bytesRead\" or r[\"_field\"] == \"bytesWritten\")" +
"|> filter(fn: (r) => r[\"namespace\"] == \"frontend\")" +
svcFilter +
shrFilter +
"|> aggregateWindow(every: 5s, fn: sum, createEmpty: true)\n" +
"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")" +
"|> yield(name: \"last\")"