prom client in chart-sync

Author: prkhrkat

pkg/chartRepo/ManualAppSyncYaml.go

@@ -23,28 +23,32 @@ import (
 )
 
 type AppSyncConfig struct {
-	DbConfig               sql.Config
-	DockerImage            string
-	AppSyncJobResourcesObj string
-	ChartProviderConfig    *ChartProviderConfig
-	AppSyncServiceAccount  string
+	DbConfig                         sql.Config
+	DockerImage                      string
+	AppSyncJobResourcesObj           string
+	ChartProviderConfig              *ChartProviderConfig
+	AppSyncServiceAccount            string
 	ParallelismLimitForTagProcessing int
+	AppSyncJobShutDownInterval       int
 }
 
 type ChartProviderConfig struct {
 	ChartProviderId string
 	IsOCIRegistry   bool
 }
 
+const AppSyncJobShutDownInterval = 60
+
 func manualAppSyncJobByteArr(dockerImage string, appSyncJobResourcesObj string, appSyncServiceAccount string, chartProviderConfig *ChartProviderConfig, ParallelismLimitForTagProcessing int) []byte {
 	cfg, _ := sql.GetConfig()
 	configValues := AppSyncConfig{
-		DbConfig:               sql.Config{Addr: cfg.Addr, Database: cfg.Database, User: cfg.User, Password: cfg.Password},
-		DockerImage:            dockerImage,
-		AppSyncJobResourcesObj: appSyncJobResourcesObj,
-		ChartProviderConfig:    chartProviderConfig,
-		AppSyncServiceAccount:  appSyncServiceAccount,
+		DbConfig:                         sql.Config{Addr: cfg.Addr, Database: cfg.Database, User: cfg.User, Password: cfg.Password},
+		DockerImage:                      dockerImage,
+		AppSyncJobResourcesObj:           appSyncJobResourcesObj,
+		ChartProviderConfig:              chartProviderConfig,
+		AppSyncServiceAccount:            appSyncServiceAccount,
 		ParallelismLimitForTagProcessing: ParallelismLimitForTagProcessing,
+		AppSyncJobShutDownInterval:       AppSyncJobShutDownInterval,
 	}
 	temp := template.New("manualAppSyncJobByteArr")
 	temp, _ = temp.Parse(`{"apiVersion": "batch/v1",
@@ -71,6 +75,10 @@ func manualAppSyncJobByteArr(dockerImage string, appSyncJobResourcesObj string,
           {
             "name": "chart-sync",
             "image": "{{.DockerImage}}",
+ 			"ports":
+                - "containerPort": 8080
+                  "name": "metrics"
+                  "protocol": "TCP"
 			{{if .AppSyncJobResourcesObj}}
 			"resources": {{.AppSyncJobResourcesObj}},
             {{end}}
@@ -102,6 +110,10 @@ func manualAppSyncJobByteArr(dockerImage string, appSyncJobResourcesObj string,
               {
 				"name": "PARALLELISM_LIMIT_FOR_TAG_PROCESSING",
      			"value": "{{.ParallelismLimitForTagProcessing}}"
+              },
+			  {
+				"name": "APP_SYNC_SHUTDOWN_INTERVAL",
+     			"value": "{{.AppSyncJobShutDownInterval}}"
               }
             ]
           }