added support for any types in metadata labels field

proxima-one · Jan 20, 2023 · cdf40aa · cdf40aa
1 parent 6955fc9
commit cdf40aa
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/cmd/dev/main.go b/cmd/dev/main.go
@@ -41,7 +41,7 @@ func getStreams() {
 }
 
 func findStreams() {
-	streams, err := streamRegistryClient.FindStreams(&proximaclient.StreamFilter{Labels: map[string]string{
+	streams, err := streamRegistryClient.FindStreams(&proximaclient.StreamFilter{Labels: map[string]any{
 		"encoding": "json",
 	}})
 	if err != nil {
@@ -131,10 +131,10 @@ func main() {
 		DebugHttpOutput: false,
 	})
 
-	// testStreamRegistryClient()
-	// testStreamDbClientFetch()
-	// testStreamDbClientStream()
-	// testStreamDbClientStreamWithBufferedReader()
+	//testStreamRegistryClient()
+	//testStreamDbClientFetch()
+	//testStreamDbClientStream()
+	//testStreamDbClientStreamWithBufferedReader()
 
 	t := time.Unix(time.Now().Unix()+10000, 0)
 	_, err := streamRegistryClient.FindOffset("proxima.eth-main.blocks.1_0", nil, &t)

diff --git a/pkg/proximaclient/client_stream_registy_client.go b/pkg/proximaclient/client_stream_registy_client.go
@@ -25,7 +25,7 @@ type StreamRegistryClientOptions struct {
 }
 
 type StreamFilter struct {
-	Labels map[string]string `json:"labels"`
+	Labels map[string]any `json:"labels"`
 }
 
 func NewStreamRegistryClient(options StreamRegistryClientOptions) *StreamRegistryClient {

diff --git a/pkg/proximaclient/model_stream_metadata.go b/pkg/proximaclient/model_stream_metadata.go
@@ -1,6 +1,6 @@
 package proximaclient
 
 type StreamMetadata struct {
-	Description string            `json:"description"`
-	Labels      map[string]string `json:"labels"`
+	Description string         `json:"description"`
+	Labels      map[string]any `json:"labels"`
 }