fix: fix comment

plugin/admin/admin.go

@@ -33,7 +33,7 @@ func New(config config.Config) (server.Plugin, error) {
 
 var log *zap.Logger
 
-// GRPCGatewayRegister provides the ability to let other plugin to share the gRPC and HTTP server.
+// GRPCGatewayRegister provides the ability to share the gRPC and HTTP server to other plugins.
 type GRPCGatewayRegister interface {
 	GRPCRegister
 	HTTPRegister

plugin/admin/subscription.go

@@ -23,7 +23,7 @@ func (s *subscriptionService) mustEmbedUnimplementedSubscriptionServiceServer()
 	return
 }
 
-// List lists subIndexer in the broker.
+// List lists subscriptions in the broker.
 func (s *subscriptionService) List(ctx context.Context, req *ListSubscriptionRequest) (*ListSubscriptionResponse, error) {
 	page, pageSize := GetPage(req.Page, req.PageSize)
 	subs, total, err := s.a.store.GetSubscriptions(page, pageSize)
@@ -36,7 +36,7 @@ func (s *subscriptionService) List(ctx context.Context, req *ListSubscriptionReq
 	}, nil
 }
 
-// Filter filters subIndexer with the request params.
+// Filter filters subscriptions with the request params.
 // Paging is not supported, and the results are not sorted in any way.
 // Using huge req.Limit can impact performance.
 func (s *subscriptionService) Filter(ctx context.Context, req *FilterSubscriptionRequest) (resp *FilterSubscriptionResponse, err error) {
@@ -120,7 +120,7 @@ func (s *subscriptionService) Filter(ctx context.Context, req *FilterSubscriptio
 	return resp, nil
 }
 
-// Subscribe makes subIndexer for the given client.
+// Subscribe makes subscriptions for the given client.
 func (s *subscriptionService) Subscribe(ctx context.Context, req *SubscribeRequest) (resp *SubscribeResponse, err error) {
 	if req.ClientId == "" {
 		return nil, ErrInvalidArgument("client_id", "cannot be empty")

plugin/admin/swagger/client.swagger.json

@@ -13,7 +13,7 @@
   "paths": {
     "/v1/clients": {
       "get": {
-        "summary": "lists clients",
+        "summary": "List clients",
         "operationId": "List",
         "responses": {
           "200": {
@@ -52,7 +52,7 @@
     },
     "/v1/clients/{client_id}": {
       "get": {
-        "summary": "Get the client for given client id.",
+        "summary": "Get the client for given client id.\nReturn NotFound error when client not found.",
         "operationId": "Get",
         "responses": {
           "200": {
@@ -81,7 +81,7 @@
         ]
       },
       "delete": {
-        "summary": "disconnect the client for given client id.",
+        "summary": "Disconnect the client for given client id.",
         "operationId": "Delete",
         "responses": {
           "200": {

plugin/admin/swagger/publish.swagger.json

@@ -13,7 +13,7 @@
   "paths": {
     "/v1/publish": {
       "post": {
-        "summary": "publish message to broker",
+        "summary": "Publish message to broker",
         "operationId": "Publish",
         "responses": {
           "200": {

plugin/admin/swagger/subscription.swagger.json

@@ -13,7 +13,7 @@
   "paths": {
     "/v1/filter_subscriptions": {
       "get": {
-        "summary": "filter subscriptions, paging is not supported in this api.",
+        "summary": "Filter subscriptions, paging is not supported in this API.",
         "operationId": "Filter",
         "responses": {
           "200": {
@@ -80,7 +80,7 @@
     },
     "/v1/subscribe": {
       "post": {
-        "summary": "subscribe topics for the client.",
+        "summary": "Subscribe topics for the client.",
         "operationId": "Subscribe",
         "responses": {
           "200": {
@@ -113,7 +113,7 @@
     },
     "/v1/subscriptions": {
       "get": {
-        "summary": "list subscriptions.",
+        "summary": "List subscriptions.",
         "operationId": "List",
         "responses": {
           "200": {
@@ -152,7 +152,7 @@
     },
     "/v1/unsubscribe": {
       "post": {
-        "summary": "unsubscribe topics for the client.",
+        "summary": "Unsubscribe topics for the client.",
         "operationId": "Unsubscribe",
         "responses": {
           "200": {

server/server.go

@@ -857,8 +857,7 @@ func (srv *server) init(opts ...Options) (err error) {
 		return fmt.Errorf("topic alias manager : %s not found", srv.config.TopicAliasManager.Type)
 	}
 
-	err = srv.loadPlugins()
-	return err
+	return srv.loadPlugins()
 }
 
 // Init initialises the options.