From a606839692a623a9df995b673170d4fb4c4189d2 Mon Sep 17 00:00:00 2001 From: thinkerou Date: Tue, 2 Jul 2019 02:28:25 +0800 Subject: [PATCH] use function instead of global var (#36) * use function instead of global var * fix lack return --- api/tag/api.go | 9 +++++---- exporter/reader/reader.go | 10 +++++----- 2 files changed, 10 insertions(+), 9 deletions(-) diff --git a/api/tag/api.go b/api/tag/api.go index 1e12c0727f8d..d9613f10294d 100644 --- a/api/tag/api.go +++ b/api/tag/api.go @@ -35,10 +35,6 @@ type Map interface { type Option func(*registeredKey) -var ( - EmptyMap = NewMap(core.KeyValue{}, nil, core.Mutator{}, nil) -) - func New(name string, opts ...Option) core.Key { // TODO rename NewKey? return register(name, opts) } @@ -49,6 +45,11 @@ func NewMeasure(name string, opts ...Option) core.Measure { } } +func NewEmptyMap() Map { + var t tagMap + return t.Apply(core.KeyValue{}, nil, core.Mutator{}, nil) +} + func NewMap(a1 core.KeyValue, attributes []core.KeyValue, m1 core.Mutator, mutators []core.Mutator) Map { var t tagMap return t.Apply(a1, attributes, m1, mutators) diff --git a/exporter/reader/reader.go b/exporter/reader/reader.go index 1e96ebb3b862..ed5e11f48a49 100644 --- a/exporter/reader/reader.go +++ b/exporter/reader/reader.go @@ -126,8 +126,8 @@ func (ro *readerObserver) Observe(event observer.Event) { read := Event{ Time: event.Time, Sequence: event.Sequence, - Attributes: tag.EmptyMap, - Tags: tag.EmptyMap, + Attributes: tag.NewEmptyMap(), + Tags: tag.NewEmptyMap(), } if event.Context != nil { @@ -201,7 +201,7 @@ func (ro *readerObserver) Observe(event observer.Event) { sid = event.Scope } if sid.EventID == 0 { - m = tag.EmptyMap + m = tag.NewEmptyMap() } else { parentI, has := ro.scopes.Load(sid.EventID) if !has { @@ -316,7 +316,7 @@ func (ro *readerObserver) addMeasurement(e *Event, m core.Measurement) { func (ro *readerObserver) readScope(id core.ScopeID) (tag.Map, *readerSpan) { if id.EventID == 0 { - return tag.EmptyMap, nil + return tag.NewEmptyMap(), nil } ev, has := ro.scopes.Load(id.EventID) if !has { @@ -327,7 +327,7 @@ func (ro *readerObserver) readScope(id core.ScopeID) (tag.Map, *readerSpan) { } else if sp, ok := ev.(*readerSpan); ok { return sp.attributes, sp } - return tag.EmptyMap, nil + return tag.NewEmptyMap(), nil } func (ro *readerObserver) cleanupSpan(id core.EventID) {