lint fix

Signed-off-by: sadath-12 <[email protected]>

Author: sadath-12

service/http/topic.go

@@ -45,7 +45,7 @@ const (
 // Merge itemMap into topicEventJSON
 type topicEventJSON struct {
 	// ID identifies the event.
-	ID string `json:"id"` // y
+	ID string `json:"id"`
 	// The version of the CloudEvents specification.
 	SpecVersion string `json:"specversion"`
 	// The type of event related to the originating occurrence.

service/internal/topicregistrar.go

@@ -14,9 +14,9 @@ type TopicRegistrar map[string]*TopicRegistration
 
 // TopicRegistration encapsulates the subscription and handlers.
 type TopicRegistration struct {
-	Subscription       *TopicSubscription
-	DefaultHandler     common.TopicEventHandler
-	RouteHandlers      map[string]common.TopicEventHandler
+	Subscription   *TopicSubscription
+	DefaultHandler common.TopicEventHandler
+	RouteHandlers  map[string]common.TopicEventHandler
 }
 
 func (m TopicRegistrar) AddSubscription(sub *common.Subscription, fn common.TopicEventHandler) error {
@@ -102,7 +102,7 @@ func (m TopicRegistrar) AddBulkSubscription(sub *common.Subscription, fn common.
 		if err := ts.Subscription.SetDefaultRoute(sub.Route); err != nil {
 			return err
 		}
-		
+
 		ts.DefaultHandler = fn
 	}
 

service/internal/topicsubscription.go

@@ -30,15 +30,14 @@ type BulkSubscribeMessageItem struct {
 }
 
 type BulkSubscribeEnvelope struct {
-	ID        string
-	Entries   []BulkSubscribeMessageItem
-	Metadata  map[string]string
-	Topic     string
-	Pubsub    string
-	EventType string
+	ID        string                     `json:"id"`
+	Entries   []BulkSubscribeMessageItem `json:"entries"`
+	Metadata  map[string]string          `json:"metadata"`
+	Topic     string                     `json:"topic"`
+	Pubsub    string                     `json:"pubsub"`
+	EventType string                     `json:"eventType"`
 }
 
-
 type BulkSubscribe struct {
 	Enabled            bool  `json:"enabled"`
 	MaxMessagesCount   int32 `json:"maxMessagesCount,omitempty"`
@@ -85,7 +84,7 @@ func (s *TopicSubscription) SetMetadata(metadata map[string]string) error {
 	return nil
 }
 
-func (s *TopicSubscription) SetBulkSubscribe(maxMessagesCount,maxAwaitDurationMs int32) error {
+func (s *TopicSubscription) SetBulkSubscribe(maxMessagesCount, maxAwaitDurationMs int32) error {
 	if s.BulkSubscribe != nil {
 		return fmt.Errorf("subscription for topic %s on pubsub %s already has bulkSubscribe set", s.Topic, s.PubsubName)
 	}