From 385b64d49c897686ad3e458f6e83adb1c4daf503 Mon Sep 17 00:00:00 2001 From: aishwarya-raimule Date: Thu, 12 Jan 2023 14:44:26 +0530 Subject: [PATCH] moved logs to getConfigs function --- main.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/main.go b/main.go index e8be5e2..1bef910 100644 --- a/main.go +++ b/main.go @@ -6,7 +6,6 @@ import ( producer_client "com.navi.medici.janus/producer" "com.navi.medici.janus/schema" server "com.navi.medici.janus/server" - "github.com/spf13/viper" "log" ) @@ -16,14 +15,11 @@ var ( cors string ) -const metrics_port = "4000" +const METRICS_PORT = "4000" func init() { configs := getConfigs() - port = configs.Server.Port - log.Printf("PORT IS: %v", port) - log.Printf(configs.Kafka.Bootstrap_Servers) - log.Printf(configs.SchemaRegistry.Endpoint) + schema.InitializeSchemaHandler(configs) producer_client.InitializeProducers(configs.Kafka, configs.Env) @@ -65,14 +61,19 @@ func getConfigs() config.Configurations { configuration.Kafka.Sasl_User = viper.GetString(configuration.Kafka.Sasl_User) configuration.Kafka.Sasl_Password = viper.GetString(configuration.Kafka.Sasl_Password) //} + + port = configuration.Server.Port cors = viper.GetString(configuration.Server.Cors) + log.Printf("PORT IS: %v", port) + log.Printf(configuration.Kafka.Bootstrap_Servers) + log.Printf(configuration.SchemaRegistry.Endpoint) return configuration } func main() { log.Printf("Serving on http://0.0.0.0:", port) httpServer, err1 := server.NewServer(port, cors) - metricsServer, err2 := server.MetricServer(metrics_port) + metricsServer, err2 := server.MetricServer(METRICS_PORT) if err1 != nil { log.Fatalln("Unable to start server, ", err1) }