library/go: abstract metrics streamer interface

abstract metrics streamer

1 files changed, 17 insertions, 9 deletions

diff --git a/library/go/core/metrics/solomon/registry_opts.go b/library/go/core/metrics/solomon/registry_opts.go
index c3df17940a..5a68a39283 100644
--- a/library/go/core/metrics/solomon/registry_opts.go
+++ b/library/go/core/metrics/solomon/registry_opts.go
@@ -9,20 +9,22 @@ import (
 )
 
 type RegistryOpts struct {
-	Separator  rune
-	Prefix     string
-	Tags       map[string]string
-	Rated      bool
-	UseNameTag bool
-	Collectors []func(metrics.Registry)
+	Separator    rune
+	Prefix       string
+	Tags         map[string]string
+	Rated        bool
+	UseNameTag   bool
+	Collectors   []func(metrics.Registry)
+	StreamFormat StreamFormat
 }
 
 // NewRegistryOpts returns new initialized instance of RegistryOpts
 func NewRegistryOpts() *RegistryOpts {
 	return &RegistryOpts{
-		Separator:  '.',
-		Tags:       make(map[string]string),
-		UseNameTag: false,
+		Separator:    '.',
+		Tags:         make(map[string]string),
+		UseNameTag:   false,
+		StreamFormat: StreamSpack,
 	}
 }
 
@@ -85,3 +87,9 @@ func (o *RegistryOpts) AddCollectors(
 	})
 	return o
 }
+
+// SetStreamFormat sets default sensors stream format
+func (o *RegistryOpts) SetStreamFormat(format StreamFormat) *RegistryOpts {
+	o.StreamFormat = format
+	return o
+}