extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2024-12-23 15:18:52 +01:00
Code Issues Packages Projects Releases Wiki Activity

better slice size management? (#324)

Browse Source
This commit is contained in:
Michael Quigley 2023-05-10 14:59:26 -04:00
parent 43e6c56ec1
commit c193482171
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
controller/metrics.go
View File

@ -39,7 +39,7 @@ func (h *getAccountMetricsHandler) Handle(params metadata.GetAccountMetricsParam
} }
duration = v duration = v
} }
slice := duration / 30 slice := sliceSize(duration)
query := fmt.Sprintf("from(bucket: \"%v\")\n", h.cfg.Bucket) + query := fmt.Sprintf("from(bucket: \"%v\")\n", h.cfg.Bucket) +
fmt.Sprintf("|> range(start: -%v)\n", duration) + fmt.Sprintf("|> range(start: -%v)\n", duration) +
@ -109,7 +109,7 @@ func (h *getEnvironmentMetricsHandler) Handle(params metadata.GetEnvironmentMetr
} }
duration = v duration = v
} }
slice := duration / 30 slice := sliceSize(duration)
query := fmt.Sprintf("from(bucket: \"%v\")\n", h.cfg.Bucket) + query := fmt.Sprintf("from(bucket: \"%v\")\n", h.cfg.Bucket) +
fmt.Sprintf("|> range(start: -%v)\n", duration) + fmt.Sprintf("|> range(start: -%v)\n", duration) +
@ -189,7 +189,7 @@ func (h *getShareMetricsHandler) Handle(params metadata.GetShareMetricsParams, p
} }
duration = v duration = v
} }
slice := duration / 30 slice := sliceSize(duration)
query := fmt.Sprintf("from(bucket: \"%v\")\n", h.cfg.Bucket) + query := fmt.Sprintf("from(bucket: \"%v\")\n", h.cfg.Bucket) +
fmt.Sprintf("|> range(start: -%v)\n", duration) + fmt.Sprintf("|> range(start: -%v)\n", duration) +
@ -239,3 +239,16 @@ func runFluxForRxTxArray(query string, queryApi api.QueryAPI) (rx, tx, timestamp
} }
return rx, tx, timestamps, nil return rx, tx, timestamps, nil
} }
func sliceSize(duration time.Duration) time.Duration {
switch duration {
case 30 * 24 * time.Hour:
return 24 * time.Hour
case 7 * 24 * time.Hour:
return 20 * time.Minute
case 24 * time.Hour:
return 5 * time.Minute
default:
return duration
}
}