gonic fix

agent/container/pkg/application/githubmodule.go

@@ -123,7 +123,7 @@ func (c *GithubApiClient) FetchVersions(packageName string) ([]Version, error) {
 	var versions []Version
 	err = json.Unmarshal(body, &versions)
 	if err != nil {
-		return nil, fmt.Errorf("error occured while unmarshalling the version %w", err)
+		return nil, fmt.Errorf("error occurred while unmarshalling the version %w", err)
 	}
 
 	return versions, nil

agent/container/pkg/application/handlers.go

@@ -12,10 +12,10 @@ import (
 	"go.opentelemetry.io/otel/attribute"
 )
 
-//githubHandler handles the github webhooks post requests.
+// githubHandler handles the github webhooks post requests.
 func (app *Application) localRegistryHandler(w http.ResponseWriter, r *http.Request) {
 
-	ctx:=context.Background()
+	ctx := context.Background()
 	tracer := otel.Tracer("container-gitlab")
 	_, span := tracer.Start(opentelemetry.BuildContext(ctx), "localRegistryHandler")
 	span.SetAttributes(attribute.String("http.method", "POST"))

agent/container/pkg/handler/api_handler.go

@@ -42,7 +42,7 @@ func (ah *APIHandler) BindRequest(r *gin.Engine) {
 
 	apiGroup := r.Group("/")
 	{
-		apiGroup.GET("/api-docs", ah.GetApiDocs)
+		apiGroup.GET("/api-docs", ah.GetAPIDocs)
 		apiGroup.GET("/status", ah.GetStatus)
 		apiGroup.POST("/event/docker/hub", ah.PostEventDockerHub)
 		apiGroup.POST("/event/azure/container", ah.PostEventAzureContainer)
@@ -54,7 +54,7 @@ func (ah *APIHandler) BindRequest(r *gin.Engine) {
 // GetApiDocs serves the Swagger API documentation generated from the OpenAPI YAML file.
 // It responds with a JSON representation of the API's endpoints, parameters, responses, and other details.
 // This endpoint can be used by tools like Swagger UI to provide interactive documentation for the API.
-func (ah *APIHandler) GetApiDocs(c *gin.Context) {
+func (ah *APIHandler) GetAPIDocs(c *gin.Context) {
 	swagger, err := api.GetSwagger()
 	if err != nil {
 		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})

agent/kubviz/plugins/events/event_metrics_utils.go

@@ -56,8 +56,8 @@ func publishK8sMetrics(id string, mtype string, mdata *v1.Event, js nats.JetStre
 		ClusterName: ClusterName,
 		ImageName:   imageName,
 	}
-	metricsJson, _ := json.Marshal(metrics)
-	_, err := js.Publish(constants.EventSubject, metricsJson)
+	metricsJSON, _ := json.Marshal(metrics)
+	_, err := js.Publish(constants.EventSubject, metricsJSON)
 	if err != nil {
 		return true, err
 	}

agent/kubviz/plugins/ketall/ketall.go

@@ -25,8 +25,8 @@ var ClusterName string = os.Getenv("CLUSTER_NAME")
 func PublishAllResources(result model.Resource, js nats.JetStreamContext) error {
 	metrics := result
 	metrics.ClusterName = ClusterName
-	metricsJson, _ := json.Marshal(metrics)
-	_, err := js.Publish(constants.EventSubject_getall_resource, metricsJson)
+	metricsJSON, _ := json.Marshal(metrics)
+	_, err := js.Publish(constants.EventSubject_getall_resource, metricsJSON)
 	if err != nil {
 		return err
 	}

agent/kubviz/plugins/kubepreupgrade/kubePreUpgrade.go

@@ -53,13 +53,13 @@ type PreferredResource map[string]ResourceStruct
 
 var (
 	k8sVersion             = "master"
-	deletedApiReplacements = map[string]groupResourceKind{
+	deletedAPIReplacements = map[string]groupResourceKind{
 		"extensions/v1beta1/Ingress": {"networking.k8s.io/v1", "ingresses", "Ingress"},
 	}
 )
 var result *model.Result
 
-func publishK8sDepricated_Deleted_Api(result *model.Result, js nats.JetStreamContext) error {
+func publishK8sDepricatedDeletedAPI(result *model.Result, js nats.JetStreamContext) error {
 	for _, deprecatedAPI := range result.DeprecatedAPIs {
 		deprecatedAPI.ClusterName = ClusterName
 		deprecatedAPIJson, _ := json.Marshal(deprecatedAPI)
@@ -109,7 +109,7 @@ func KubePreUpgradeDetector(config *rest.Config, js nats.JetStreamContext) error
 		return err
 	}
 	result = getResults(config, kubernetesAPIs)
-	err = publishK8sDepricated_Deleted_Api(result, js)
+	err = publishK8sDepricatedDeletedAPI(result, js)
 	return err
 }
 
@@ -371,7 +371,7 @@ func getResults(configRest *rest.Config, kubeAPIs model.KubernetesAPIs) *model.R
 
 				gvr, list := getResources(client, groupResourceKind{resourceGroupVersion.GroupVersion, resource.Name, resource.Kind})
 
-				if newApi, ok := deletedApiReplacements[keyAPI]; ok {
+				if newApi, ok := deletedAPIReplacements[keyAPI]; ok {
 					list.Items = fixDeletedItemsList(client, list.Items, newApi)
 				}
 

agent/kubviz/plugins/kubescore/kube_score.go

@@ -56,9 +56,6 @@ func publish(ns string, js nats.JetStreamContext) error {
 
 	publishKubescoreMetrics(report, js)
 	//err = publishKubescoreMetrics(uuid.New().String(), ns, out, js)
-	if err != nil {
-		return err
-	}
 	return nil
 }
 
@@ -75,8 +72,8 @@ func publishKubescoreMetrics(report []json_v2.ScoredObject, js nats.JetStreamCon
 		ClusterName: ClusterName,
 		Report:      report,
 	}
-	metricsJson, _ := json.Marshal(metrics)
-	_, err := js.Publish(constants.KUBESCORE_SUBJECT, metricsJson)
+	metricsJSON, _ := json.Marshal(metrics)
+	_, err := js.Publish(constants.KUBESCORE_SUBJECT, metricsJSON)
 	if err != nil {
 		return err
 	}

agent/kubviz/plugins/outdated/outdated.go

@@ -70,8 +70,8 @@ func PublishOutdatedImages(out model.CheckResultfinal, js nats.JetStreamContext)
 
 	metrics := out
 	metrics.ClusterName = ClusterName
-	metricsJson, _ := json.Marshal(metrics)
-	_, err := js.Publish(constants.EventSubject_outdated_images, metricsJson)
+	metricsJSON, _ := json.Marshal(metrics)
+	_, err := js.Publish(constants.EventSubject_outdated_images, metricsJSON)
 	if err != nil {
 		return err
 	}

agent/kubviz/plugins/rakkess/rakees_agent.go

@@ -95,8 +95,8 @@ func RakeesOutput(config *rest.Config, js nats.JetStreamContext) error {
 			List:        HumanreadableAccessCode(listOutcome),
 			Update:      HumanreadableAccessCode(updateOutcome),
 		}
-		metricsJson, _ := json.Marshal(metrics)
-		_, err = js.Publish(constants.EventSubject_rakees, metricsJson)
+		metricsJSON, _ := json.Marshal(metrics)
+		_, err = js.Publish(constants.EventSubject_rakees, metricsJSON)
 		if err != nil {
 			return err
 		}

agent/kubviz/plugins/trivy/trivy.go

@@ -100,8 +100,8 @@ func PublishTrivyK8sReport(report report.ConsolidatedReport, js nats.JetStreamCo
 		ClusterName: ClusterName,
 		Report:      report,
 	}
-	metricsJson, _ := json.Marshal(metrics)
-	_, err := js.Publish(constants.TRIVY_K8S_SUBJECT, metricsJson)
+	metricsJSON, _ := json.Marshal(metrics)
+	_, err := js.Publish(constants.TRIVY_K8S_SUBJECT, metricsJSON)
 	if err != nil {
 		return err
 	}

agent/kubviz/plugins/trivy/trivy_image.go

@@ -42,7 +42,7 @@ func RunTrivyImageScans(config *rest.Config, js nats.JetStreamContext) error {
 
 	images, err := ListImages(config)
 	if err != nil {
-		log.Println("error occured while trying to list images, error :", err.Error())
+		log.Println("error occurred while trying to list images, error :", err.Error())
 		return err
 	}
 
@@ -90,8 +90,8 @@ func PublishImageScanReports(report types.Report, js nats.JetStreamContext) erro
 		ClusterName: ClusterName,
 		Report:      report,
 	}
-	metricsJson, _ := json.Marshal(metrics)
-	_, err := js.Publish(constants.TRIVY_IMAGE_SUBJECT, metricsJson)
+	metricsJSON, _ := json.Marshal(metrics)
+	_, err := js.Publish(constants.TRIVY_IMAGE_SUBJECT, metricsJSON)
 	if err != nil {
 		return err
 	}

agent/kubviz/plugins/trivy/trivy_sbom.go

@@ -29,12 +29,12 @@ func PublishTrivySbomReport(report map[string]interface{}, js nats.JetStreamCont
 		ClusterName: ClusterName,
 		Report:      report,
 	}
-	metricsJson, err := json.Marshal(metrics)
+	metricsJSON, err := json.Marshal(metrics)
 	if err != nil {
 		log.Println("error occurred while marshalling sbom metrics in agent", err.Error())
 		return err
 	}
-	_, err = js.Publish(constants.TRIVY_SBOM_SUBJECT, metricsJson)
+	_, err = js.Publish(constants.TRIVY_SBOM_SUBJECT, metricsJSON)
 	if err != nil {
 		return err
 	}

client/pkg/clickhouse/db_client.go

@@ -60,7 +60,7 @@ func NewDBClient(conf *config.Config) (DBInterface, *sql.DB, error) {
 	if conf.ClickHouseUsername != "" && conf.ClickHousePassword != "" {
 		fmt.Println("Using provided username and password")
 		connOptions = clickhouse.Options{
-			Addr:  []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DbPort)},
+			Addr:  []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DBPort)},
 			Debug: true,
 			Auth: clickhouse.Auth{
 				Username: conf.ClickHouseUsername,
@@ -77,7 +77,7 @@ func NewDBClient(conf *config.Config) (DBInterface, *sql.DB, error) {
 	} else {
 		fmt.Println("Using connection without username and password")
 		connOptions = clickhouse.Options{
-			Addr:  []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DbPort)},
+			Addr:  []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DBPort)},
 			Debug: true,
 			Debugf: func(format string, v ...interface{}) {
 				fmt.Printf(format, v...)
@@ -109,7 +109,7 @@ func NewDBClient(conf *config.Config) (DBInterface, *sql.DB, error) {
 	if conf.ClickHouseUsername != "" && conf.ClickHousePassword != "" {
 		fmt.Println("Using provided username and password")
 		connOption = clickhouse.Options{
-			Addr:  []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DbPort)},
+			Addr:  []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DBPort)},
 			Debug: true,
 			Auth: clickhouse.Auth{
 				Username: conf.ClickHouseUsername,
@@ -119,7 +119,7 @@ func NewDBClient(conf *config.Config) (DBInterface, *sql.DB, error) {
 	} else {
 		fmt.Println("Using connection without username and password")
 		connOption = clickhouse.Options{
-			Addr: []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DbPort)},
+			Addr: []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DBPort)},
 		}
 	}
 
@@ -583,7 +583,7 @@ func (c *DBClient) InsertKubvizEvent(metrics model.Metrics) {
 	}
 
 	defer stmt.Close()
-	eventJson, _ := json.Marshal(metrics.Event)
+	eventJSON, _ := json.Marshal(metrics.Event)
 	formattedFirstTimestamp := metrics.Event.FirstTimestamp.Time.UTC().Format("2006-01-02 15:04:05")
 	formattedLastTimestamp := metrics.Event.LastTimestamp.Time.UTC().Format("2006-01-02 15:04:05")
 
@@ -598,7 +598,7 @@ func (c *DBClient) InsertKubvizEvent(metrics model.Metrics) {
 		metrics.Event.Message,
 		metrics.Event.Reason,
 		metrics.Event.Source.Host,
-		string(eventJson),
+		string(eventJSON),
 		metrics.ImageName,
 		formattedFirstTimestamp,
 		formattedLastTimestamp,
@@ -936,7 +936,7 @@ func (c *DBClient) Close() {
 }
 
 func DbUrl(conf *config.Config) string {
-	return fmt.Sprintf("tcp://%s:%d?debug=true", conf.DBAddress, conf.DbPort)
+	return fmt.Sprintf("tcp://%s:%d?debug=true", conf.DBAddress, conf.DBPort)
 }
 func (c *DBClient) RetriveKetallEvent() ([]model.Resource, error) {
 	rows, err := c.conn.Query("SELECT ClusterName, Namespace, Kind, Resource, Age FROM getall_resources")
@@ -1018,8 +1018,8 @@ func (c *DBClient) RetrieveKubvizEvent() ([]model.DbEvent, error) {
 			log.Printf("Error: %s", err)
 			return nil, err
 		}
-		eventJson, _ := json.Marshal(dbEvent)
-		log.Printf("DB Event: %s", string(eventJson))
+		eventJSON, _ := json.Marshal(dbEvent)
+		log.Printf("DB Event: %s", string(eventJSON))
 		events = append(events, dbEvent)
 	}