Standardize Metrics In Memory Storage

Signed-off-by: Mahad Zaryab <[email protected]>

plugin/storage/memory/factory.go

@@ -82,7 +82,14 @@ func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger)
 
 // CreateSpanReader implements storage.Factory
 func (f *Factory) CreateSpanReader() (spanstore.Reader, error) {
-	return spanstoremetrics.NewReaderDecorator(f.store, f.metricsFactory), nil
+	primaryMetricsFactory := f.metricsFactory.Namespace(
+		metrics.NSOptions{
+			Tags: map[string]string{
+				"role": "primary",
+			},
+		},
+	)
+	return spanstoremetrics.NewReaderDecorator(f.store, primaryMetricsFactory), nil
 }
 
 // CreateSpanWriter implements storage.Factory
@@ -92,7 +99,14 @@ func (f *Factory) CreateSpanWriter() (spanstore.Writer, error) {
 
 // CreateArchiveSpanReader implements storage.ArchiveFactory
 func (f *Factory) CreateArchiveSpanReader() (spanstore.Reader, error) {
-	return f.store, nil
+	archiveMetricsFactory := f.metricsFactory.Namespace(
+		metrics.NSOptions{
+			Tags: map[string]string{
+				"role": "archive",
+			},
+		},
+	)
+	return spanstoremetrics.NewReaderDecorator(f.store, archiveMetricsFactory), nil
 }
 
 // CreateArchiveSpanWriter implements storage.ArchiveFactory