release v0.3.3

Taskfile.yml

@@ -4,7 +4,7 @@ version: '3'
 
 vars:
   BINARY_NAME: kubemq-bridges
-  VERSION: v0.3.2
+  VERSION: v0.3.3
 
 tasks:
   check_update:

go.mod

@@ -10,7 +10,7 @@ require (
 	github.com/golang/groupcache v0.0.0-20200121045136-8c9f03a8e57e // indirect
 	github.com/json-iterator/go v1.1.10
 	github.com/kr/pretty v0.2.0 // indirect
-	github.com/kubemq-hub/builder v0.5.1
+	github.com/kubemq-hub/builder v0.5.6
 	github.com/kubemq-io/kubemq-go v1.4.4
 	github.com/labstack/echo/v4 v4.1.17
 	github.com/nats-io/nuid v1.0.1

go.sum

@@ -195,6 +195,8 @@ github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kubemq-hub/builder v0.5.1 h1:2DPovJdN20E7y6zN1/tPh1c9L/kdnk7dWC6P2dLSznY=
 github.com/kubemq-hub/builder v0.5.1/go.mod h1:mecBYg2ed+D050hNlGlTUWLyhKILU+MBic+zgV3P25g=
+github.com/kubemq-hub/builder v0.5.6 h1:aIrGLJvinIe7BS14T2y8f8ZMWXIVzXZVg44g9cQZAdE=
+github.com/kubemq-hub/builder v0.5.6/go.mod h1:mecBYg2ed+D050hNlGlTUWLyhKILU+MBic+zgV3P25g=
 github.com/kubemq-io/kubemq-go v1.4.4 h1:S+GjYJDjKPhTOqDdSYn2RRtsxJbb5Amk75xSSQeC2Hk=
 github.com/kubemq-io/kubemq-go v1.4.4/go.mod h1:J8TEMk85d+00r+H3KIaSy/zLTXdQ7OLhVyF1WuXuZt0=
 github.com/kubemq-io/protobuf v1.1.0 h1:MaNkRULq/wlU9o9jwx6HORtz2RngpudmxShQ+86CqcU=

pkg/metrics/exporter.go

@@ -6,7 +6,7 @@ import (
 	"net/http"
 )
 
-var labels = []string{"binding", "source_name", "source_kind", "target_name", "target_kind"}
+var labels = []string{"binding", "source_kind", "target_kind"}
 
 type Exporter struct {
 	Store                    *Store

sources/source.go

@@ -21,31 +21,31 @@ type Source interface {
 
 func Init(ctx context.Context, kind string, connection config.Metadata) (Source, error) {
 	switch kind {
-	case "source.command":
+	case "source.command", "kubemq.command":
 		source := command.New()
 		if err := source.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return source, nil
-	case "source.query":
+	case "source.query", "kubemq.query":
 		source := query.New()
 		if err := source.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return source, nil
-	case "source.events":
+	case "source.events", "kubemq.events":
 		source := events.New()
 		if err := source.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return source, nil
-	case "source.events-store":
+	case "source.events-store", "kubemq.events-store":
 		source := events_store.New()
 		if err := source.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return source, nil
-	case "source.queue":
+	case "source.queue", "kubemq.queue":
 		source := queue.New()
 		if err := source.Init(ctx, connection); err != nil {
 			return nil, err

targets/target.go

@@ -20,31 +20,31 @@ type Target interface {
 func Init(ctx context.Context, kind string, connection config.Metadata) (Target, error) {
 
 	switch kind {
-	case "target.command":
+	case "target.command", "kubemq.command":
 		target := command.New()
 		if err := target.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return target, nil
-	case "target.query":
+	case "target.query", "kubemq.query":
 		target := query.New()
 		if err := target.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return target, nil
-	case "target.events":
+	case "target.events", "kubemq.events":
 		target := events.New()
 		if err := target.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return target, nil
-	case "target.events-store":
+	case "target.events-store", "kubemq.events-store":
 		target := events_store.New()
 		if err := target.Init(ctx, connection); err != nil {
 			return nil, err
 		}
 		return target, nil
-	case "target.queue":
+	case "target.queue", "kubemq.queue":
 		target := queue.New()
 		if err := target.Init(ctx, connection); err != nil {
 			return nil, err

vendor/modules.txt

@@ -70,7 +70,7 @@ github.com/json-iterator/go
 github.com/kballard/go-shellquote
 # github.com/kr/pretty v0.2.0
 ## explicit
-# github.com/kubemq-hub/builder v0.5.1
+# github.com/kubemq-hub/builder v0.5.6
 ## explicit
 github.com/kubemq-hub/builder/connector/bridges
 github.com/kubemq-hub/builder/connector/bridges/source