Merge pull request #17 from baibikov/tcp-routing

feat(routing): use interface type into comparable
baibikov · Sep 19, 2022 · ca0d607 · ca0d607
2 parents 2b62b47 + 424a563
commit ca0d607
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/internal/tcp/broadcast.go b/internal/tcp/broadcast.go
@@ -102,7 +102,7 @@ func (h *handler) distribute() error {
 
 	logrus.Debugf("processing message by type - %d", typ)
 
-	route := routing.New(map[comparable]routing.HandlerFunc{
+	route := routing.New(map[interface{}]routing.HandlerFunc{
 		setMessageType:    h.set,
 		getMessageType:    h.get,
 		commitMessageType: h.commit,

diff --git a/pkg/routing/routing.go b/pkg/routing/routing.go
@@ -5,16 +5,16 @@ import "github.com/pkg/errors"
 type HandlerFunc func() error
 
 type Routing struct {
-	handlers map[comparable]HandlerFunc
+	handlers map[interface{}]HandlerFunc
 }
 
-func New(handlers map[comparable]HandlerFunc) *Routing {
+func New(handlers map[interface{}]HandlerFunc) *Routing {
 	return &Routing{
 		handlers: handlers,
 	}
 }
 
-func (r *Routing) Distribute(k comparable) error {
+func (r *Routing) Distribute(k interface{}) error {
 	hh, ok := r.handlers[k]
 	if !ok {
 		return errors.Errorf("undefined key to distribute - %+v", k)