Add interface in topic

mpsdantas · Mar 15, 2024 · 48cbc71 · 48cbc71
1 parent 97fef52
commit 48cbc71
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/pkg/pubsub/pubsub.go b/pkg/pubsub/pubsub.go
@@ -34,8 +34,8 @@ func (c *Client) Close() {
 	}
 }
 
-func (c *Client) Topic(id string) *Topic {
-	return &Topic{
+func (c *Client) Topic(id string) Topic {
+	return &topic{
 		tp: c.clt.Topic(id),
 	}
 }
diff --git a/pkg/pubsub/topic.go b/pkg/pubsub/topic.go
@@ -8,11 +8,15 @@ import (
 	"github.com/mpsdantas/bottle/pkg/log"
 )
 
-type Topic struct {
+type Topic interface {
+	Publish(ctx context.Context, event string, value interface{})
+}
+
+type topic struct {
 	tp *pubsub.Topic
 }
 
-func (t *Topic) Publish(ctx context.Context, event string, value interface{}) {
+func (t *topic) Publish(ctx context.Context, event string, value interface{}) {
 	go func(c context.Context) {
 		data, err := json.Marshal(value)
 		if err != nil {