update api reload

Taskfile.yml

@@ -4,7 +4,7 @@ version: '2'
 
 vars:
   BINARY_NAME: kubemq-bridges
-  VERSION: v0.1.5
+  VERSION: v0.1.6
 
 tasks:
   check_update:
@@ -29,11 +29,14 @@ tasks:
       - go mod vendor
       - docker build --build-arg VERSION={{.VERSION}} . -t kubemq/{{.BINARY_NAME}}:{{.VERSION}}
       - docker tag kubemq/{{.BINARY_NAME}}:{{.VERSION}} kubemq/{{.BINARY_NAME}}:latest
+  push:
+    cmds:
+      - docker push kubemq/{{.BINARY_NAME}}:{{.VERSION}}
+      - docker push kubemq/{{.BINARY_NAME}}:latest
   release:
     cmds:
       - task: lint
       - git tag -a {{.VERSION}} -m {{.VERSION}}
       - git push origin master --tags
       - task: docker
-      - docker push kubemq/{{.BINARY_NAME}}:{{.VERSION}}
-      - docker push kubemq/{{.BINARY_NAME}}:latest
+      - task: push

api/server.go

@@ -56,8 +56,8 @@ func Start(ctx context.Context, port int, bs *binding.Service) (*Server, error)
 	}
 }
 
-func (s *Server) Stop() {
+func (s *Server) Stop() error {
 	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
 	defer cancel()
-	_ = s.echoWebServer.Shutdown(ctx)
+	 return s.echoWebServer.Shutdown(ctx)
 }

main.go

@@ -63,13 +63,24 @@ func run() error {
 				log.Errorf("error on restarting service with new config file: %s", err.Error())
 				continue
 			}
-		case <-gracefulShutdown:
+			if apiServer != nil {
+				err = apiServer.Stop()
+				if err != nil {
+					log.Errorf("error on shutdown api server: %s", err.Error())
+					continue
+				}
+			}
 
-			apiServer.Stop()
+			apiServer, err = api.Start(ctx, newConfig.ApiPort, bindingsService)
+			if err != nil {
+				log.Errorf("error on start api server: %s", err.Error())
+				continue
+			}
+		case <-gracefulShutdown:
+			_=apiServer.Stop()
 			bindingsService.Stop()
 			return nil
 		}
-
 	}
 
 }