services: add more logger

Author: wuriyanto48

services/kafka/kafka.go

@@ -54,6 +54,10 @@ func (d *Kafka) Ping() []byte {
 
 	reply, err := d.client.Brokers()
 	if err != nil {
+		if d.verbose {
+			d.logger.Println("Kafka error read available brokers")
+			d.logger.Println(err)
+		}
 		return []byte("NOT_OK")
 	}
 

services/mongodb/mongo.go

@@ -50,6 +50,10 @@ func (d *Mongo) Ping() []byte {
 	}
 
 	if err := d.client.Ping(context.Background(), nil); err != nil {
+		if d.verbose {
+			d.logger.Println("MongoDB error")
+			d.logger.Println(err)
+		}
 		return []byte("NOT_OK")
 	}
 

services/mysqldb/mysql.go

@@ -49,6 +49,10 @@ func (d *MySQL) Ping() []byte {
 	}
 
 	if err := d.db.Ping(); err != nil {
+		if d.verbose {
+			d.logger.Println("MySQL error")
+			d.logger.Println(err)
+		}
 		return []byte("NOT_OK")
 	}
 

services/postgres/postgres.go

@@ -49,6 +49,10 @@ func (d *Postgres) Ping() []byte {
 	}
 
 	if err := d.db.Ping(); err != nil {
+		if d.verbose {
+			d.logger.Println("Postgre error")
+			d.logger.Println(err)
+		}
 		return []byte("NOT_OK")
 	}
 

services/redisdb/redis.go

@@ -51,6 +51,10 @@ func (d *Redis) Ping() []byte {
 
 	reply := d.client.Ping(context.Background())
 	if reply.Err() != nil {
+		if d.verbose {
+			d.logger.Println("Redis error")
+			d.logger.Println(reply.Err())
+		}
 		return []byte("NOT_OK")
 	}