Add missing comments

internal/util/nats/message.go

@@ -1,5 +1,7 @@
 package nats
 
+// Msg represent a message send-able trough NATS
 type Msg interface {
+	// Subject returns the subject where message should be push
 	Subject() string
 }

internal/util/nats/nats.go

@@ -6,10 +6,12 @@ import (
 	"github.com/nats-io/nats.go"
 )
 
+// PublishMsg publish given Msg
 func PublishMsg(nc *nats.Conn, msg Msg) error {
 	return PublishJSON(nc, msg.Subject(), msg)
 }
 
+// ReadMsg read message from given connection
 func ReadMsg(nc *nats.Msg, msg Msg) error {
 	return ReadJSON(nc, msg)
 }

pkg/proto/proto.go

@@ -16,6 +16,7 @@ type URLTodoMsg struct {
 	URL string `json:"url"`
 }
 
+// Subject returns the subject where message should be push
 func (msg *URLTodoMsg) Subject() string {
 	return URLTodoSubject
 }
@@ -25,15 +26,18 @@ type URLFoundMsg struct {
 	URL string `json:"url"`
 }
 
+// Subject returns the subject where message should be push
 func (msg *URLFoundMsg) Subject() string {
 	return URLFoundSubject
 }
 
+// NewResourceMsg represent a crawled resource
 type NewResourceMsg struct {
 	URL  string `json:"url"`
 	Body string `json:"body"`
 }
 
+// Subject returns the subject where message should be push
 func (msg *NewResourceMsg) Subject() string {
 	return NewResourceSubject
 }