[#1695] qos: Sort tags by asc
All checks were successful
Vulncheck / Vulncheck (push) Successful in 1m5s
Pre-commit hooks / Pre-commit (push) Successful in 1m29s
Build / Build Components (push) Successful in 1m58s
Tests and linters / Run gofumpt (push) Successful in 2m47s
Tests and linters / Tests (push) Successful in 3m18s
Tests and linters / Lint (push) Successful in 3m25s
Tests and linters / Staticcheck (push) Successful in 3m21s
Tests and linters / Tests with -race (push) Successful in 3m26s
Tests and linters / gopls check (push) Successful in 3m40s
OCI image / Build container images (push) Successful in 4m39s
All checks were successful
Vulncheck / Vulncheck (push) Successful in 1m5s
Pre-commit hooks / Pre-commit (push) Successful in 1m29s
Build / Build Components (push) Successful in 1m58s
Tests and linters / Run gofumpt (push) Successful in 2m47s
Tests and linters / Tests (push) Successful in 3m18s
Tests and linters / Lint (push) Successful in 3m25s
Tests and linters / Staticcheck (push) Successful in 3m21s
Tests and linters / Tests with -race (push) Successful in 3m26s
Tests and linters / gopls check (push) Successful in 3m40s
OCI image / Build container images (push) Successful in 4m39s
Change-Id: Ia23e392bb49d2536096de2ba07fc6f8fb7ac0489 Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
parent
3fa5c22ddf
commit
af76350bfb
4 changed files with 18 additions and 18 deletions
|
@ -74,7 +74,7 @@ func createScheduler(config limits.OpConfig) (scheduler, error) {
|
||||||
|
|
||||||
func converToSchedulingTags(limits []limits.IOTagConfig) map[string]scheduling.TagInfo {
|
func converToSchedulingTags(limits []limits.IOTagConfig) map[string]scheduling.TagInfo {
|
||||||
result := make(map[string]scheduling.TagInfo)
|
result := make(map[string]scheduling.TagInfo)
|
||||||
for _, tag := range []IOTag{IOTagClient, IOTagBackground, IOTagInternal, IOTagPolicer, IOTagWritecache, IOTagTreeSync} {
|
for _, tag := range []IOTag{IOTagBackground, IOTagClient, IOTagInternal, IOTagPolicer, IOTagTreeSync, IOTagWritecache} {
|
||||||
result[tag.String()] = scheduling.TagInfo{
|
result[tag.String()] = scheduling.TagInfo{
|
||||||
Share: defaultShare,
|
Share: defaultShare,
|
||||||
}
|
}
|
||||||
|
|
|
@ -3,13 +3,13 @@ package qos
|
||||||
const unknownStatsTag = "unknown"
|
const unknownStatsTag = "unknown"
|
||||||
|
|
||||||
var statTags = map[string]struct{}{
|
var statTags = map[string]struct{}{
|
||||||
IOTagClient.String(): {},
|
|
||||||
IOTagBackground.String(): {},
|
IOTagBackground.String(): {},
|
||||||
|
IOTagClient.String(): {},
|
||||||
|
IOTagCritical.String(): {},
|
||||||
IOTagInternal.String(): {},
|
IOTagInternal.String(): {},
|
||||||
IOTagPolicer.String(): {},
|
IOTagPolicer.String(): {},
|
||||||
IOTagWritecache.String(): {},
|
|
||||||
IOTagCritical.String(): {},
|
|
||||||
IOTagTreeSync.String(): {},
|
IOTagTreeSync.String(): {},
|
||||||
|
IOTagWritecache.String(): {},
|
||||||
unknownStatsTag: {},
|
unknownStatsTag: {},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -10,33 +10,33 @@ import (
|
||||||
type IOTag string
|
type IOTag string
|
||||||
|
|
||||||
const (
|
const (
|
||||||
IOTagClient IOTag = "client"
|
|
||||||
IOTagInternal IOTag = "internal"
|
|
||||||
IOTagBackground IOTag = "background"
|
IOTagBackground IOTag = "background"
|
||||||
|
IOTagClient IOTag = "client"
|
||||||
|
IOTagCritical IOTag = "critical"
|
||||||
|
IOTagInternal IOTag = "internal"
|
||||||
|
IOTagPolicer IOTag = "policer"
|
||||||
IOTagTreeSync IOTag = "treesync"
|
IOTagTreeSync IOTag = "treesync"
|
||||||
IOTagWritecache IOTag = "writecache"
|
IOTagWritecache IOTag = "writecache"
|
||||||
IOTagPolicer IOTag = "policer"
|
|
||||||
IOTagCritical IOTag = "critical"
|
|
||||||
|
|
||||||
ioTagUnknown IOTag = ""
|
ioTagUnknown IOTag = ""
|
||||||
)
|
)
|
||||||
|
|
||||||
func FromRawString(s string) (IOTag, error) {
|
func FromRawString(s string) (IOTag, error) {
|
||||||
switch s {
|
switch s {
|
||||||
case string(IOTagCritical):
|
|
||||||
return IOTagCritical, nil
|
|
||||||
case string(IOTagClient):
|
|
||||||
return IOTagClient, nil
|
|
||||||
case string(IOTagInternal):
|
|
||||||
return IOTagInternal, nil
|
|
||||||
case string(IOTagBackground):
|
case string(IOTagBackground):
|
||||||
return IOTagBackground, nil
|
return IOTagBackground, nil
|
||||||
case string(IOTagWritecache):
|
case string(IOTagClient):
|
||||||
return IOTagWritecache, nil
|
return IOTagClient, nil
|
||||||
|
case string(IOTagCritical):
|
||||||
|
return IOTagCritical, nil
|
||||||
|
case string(IOTagInternal):
|
||||||
|
return IOTagInternal, nil
|
||||||
case string(IOTagPolicer):
|
case string(IOTagPolicer):
|
||||||
return IOTagPolicer, nil
|
return IOTagPolicer, nil
|
||||||
case string(IOTagTreeSync):
|
case string(IOTagTreeSync):
|
||||||
return IOTagTreeSync, nil
|
return IOTagTreeSync, nil
|
||||||
|
case string(IOTagWritecache):
|
||||||
|
return IOTagWritecache, nil
|
||||||
default:
|
default:
|
||||||
return ioTagUnknown, fmt.Errorf("unknown tag %s", s)
|
return ioTagUnknown, fmt.Errorf("unknown tag %s", s)
|
||||||
}
|
}
|
||||||
|
|
|
@ -42,12 +42,12 @@ func validateOpConfig(c limits.OpConfig) error {
|
||||||
|
|
||||||
func validateTags(configTags []limits.IOTagConfig) error {
|
func validateTags(configTags []limits.IOTagConfig) error {
|
||||||
tags := map[IOTag]tagConfig{
|
tags := map[IOTag]tagConfig{
|
||||||
|
IOTagBackground: {},
|
||||||
IOTagClient: {},
|
IOTagClient: {},
|
||||||
IOTagInternal: {},
|
IOTagInternal: {},
|
||||||
IOTagBackground: {},
|
|
||||||
IOTagWritecache: {},
|
|
||||||
IOTagPolicer: {},
|
IOTagPolicer: {},
|
||||||
IOTagTreeSync: {},
|
IOTagTreeSync: {},
|
||||||
|
IOTagWritecache: {},
|
||||||
}
|
}
|
||||||
for _, t := range configTags {
|
for _, t := range configTags {
|
||||||
tag, err := FromRawString(t.Tag)
|
tag, err := FromRawString(t.Tag)
|
||||||
|
|
Loading…
Add table
Reference in a new issue