From 9fb6d84d8089b47ae262cd2173b90970e71f20d8 Mon Sep 17 00:00:00 2001 From: Cody Soyland Date: Mon, 10 Jun 2019 08:18:30 -0500 Subject: [PATCH] Remove extraneous stat tags to improve prometheus performance --- api.go | 2 +- field.go | 2 +- index.go | 2 +- view.go | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/api.go b/api.go index bdaa35b03..6a802526b 100644 --- a/api.go +++ b/api.go @@ -418,7 +418,7 @@ func (api *API) DeleteAvailableShard(_ context.Context, indexName, fieldName str api.server.logger.Printf("problem sending DeleteAvailableShard message: %s", err) return errors.Wrap(err, "sending DeleteAvailableShard message") } - api.holder.Stats.CountWithCustomTags("deleteAvailableShard", 1, 1.0, []string{fmt.Sprintf("index:%s", indexName), fmt.Sprintf("field:%s", fieldName)}) + api.holder.Stats.CountWithCustomTags("deleteAvailableShard", 1, 1.0, []string{fmt.Sprintf("index:%s", indexName)}) return nil } diff --git a/field.go b/field.go index 3e71af589..8e73ca88e 100644 --- a/field.go +++ b/field.go @@ -820,7 +820,7 @@ func (f *Field) newView(path, name string) *view { view := newView(path, f.index, f.name, name, f.options) view.logger = f.logger view.rowAttrStore = f.rowAttrStore - view.stats = f.Stats.WithTags(fmt.Sprintf("view:%s", name)) + view.stats = f.Stats view.broadcaster = f.broadcaster return view } diff --git a/index.go b/index.go index dbb9c052a..bef4ff38d 100644 --- a/index.go +++ b/index.go @@ -405,7 +405,7 @@ func (i *Index) newField(path, name string) (*Field, error) { return nil, err } f.logger = i.logger - f.Stats = i.Stats.WithTags(fmt.Sprintf("field:%s", name)) + f.Stats = i.Stats f.broadcaster = i.broadcaster f.rowAttrStore = i.newAttrStore(filepath.Join(f.path, ".data")) return f, nil diff --git a/view.go b/view.go index bd917f407..5aba4dbd3 100644 --- a/view.go +++ b/view.go @@ -267,7 +267,7 @@ func (v *view) newFragment(path string, shard uint64) *fragment { frag.CacheType = v.cacheType frag.CacheSize = v.cacheSize frag.Logger = v.logger - frag.stats = v.stats.WithTags(fmt.Sprintf("shard:%d", shard)) + frag.stats = v.stats if v.fieldType == FieldTypeMutex { frag.mutexVector = newRowsVector(frag) } else if v.fieldType == FieldTypeBool {