Гибка система логирования на Go

package GeneralsLog  import ( 	"encoding/json" 	"gopkg.in/redis.v3" 	"io/ioutil" 	"log" 	"microService/libs/mail" 	"time" )  type Config struct { 	MailTo, MailConf, Types, EmailSend, Redis, MysqlConnect []string 	MysqlTable                                              string }  var ( 	R           *redis.Client 	MailConf    map[string]string 	MailTo      []string 	Types       []string 	EmailSend   []string 	RedisConfig []string  	//Путь к файлу с конфигами 	config_file string = "/home/v-smerti/localhost/api/src/microService/config/log.json" )  func init() {  	//Спарсим конфиг 	bs, err := ioutil.ReadFile(config_file) 	if err != nil { 		log.Panicln(err) 	}  	b := []byte(bs) 	var conf Config 	err = json.Unmarshal(b, &conf) 	if err != nil { 		log.Panicln(err) 	} 	//Передаём данные с конфиг файла в глобальные переменные 	MailConf = map[string]string{ 		"username": conf.MailConf[0], 		"password": conf.MailConf[1], 		"host":     conf.MailConf[2], 		"port":     conf.MailConf[3], 	}  	MailTo = conf.MailTo 	Types = conf.Types 	EmailSend = conf.EmailSend 	RedisConfig = conf.Redis  	//Конект с редисом 	R = redis.NewClient(&redis.Options{ 		Addr:     RedisConfig[0], 		Password: RedisConfig[1], 		DB:       0, 	}) 	//Инициализация пакета. Здесь проверям есть ли в редисе такие типы логов. Если нет то создаём 	for _, typ := range Types { 		_, err := R.Get(RedisConfig[2] + typ).Result() 		if err == redis.Nil { 			if err := R.Set(RedisConfig[2]+typ, " ", 0).Err(); err != nil { 				mail.Send(MailConf, MailTo, "Fatal error game", "package GeneralsLog func Init____R.Set (Создание пустой записи в редис ключ "+typ+")") 			} 		} else if err != nil { 			mail.Send(MailConf, MailTo, "Fatal error game", "package GeneralsLog func Init____R.Set (Проверка записи "+typ+" в редисе)") 		} 	} }  func New(types string, messages string) { 	for _, typ := range Types { 		if typ == types { 			if data, err := R.Get(RedisConfig[2] + typ).Result(); err == nil {  				//Надо для проверки текущего типа в списке на отправку уведомления на e-mail 				for _, b := range EmailSend { 					//надо отправлять 					if b == typ { 						mail.Send(MailConf, MailTo, typ, messages) 					} 				}  				data = data + "('" + types + "','" + time.Now().String() + "','" + messages + "'),"  				if err := R.Set(RedisConfig[2]+typ, data, 0).Err(); err != nil { 					mail.Send(MailConf, MailTo, "Fatal error game", "package GeneralsLog func "+typ+"____R.Set (Обновление записи в редисе)") 				} 			} else { 				mail.Send(MailConf, MailTo, "Fatal error game", "package GeneralsLog func "+typ+"____R.Get (Получение данных с редиса)") 			} 		} else { 		} 	}  }  

import (
«database/sql»
_ «github.com/go-sql-driver/mysql» //можно подключить любую sql базу данных
«gopkg.in/redis.v3»
«log»
«microService/libs/mail»
«strings»
«time»

«encoding/json»
«io/ioutil»
)

type Config struct {
MailTo, MailConf, Types, EmailSend, Redis, MysqlConnect []string
MysqlTable string
ReplicationTimeSecond time.Duration
}

var (
DB *sql.DB
R *redis.Client
MailConf map[string]string
MailTo []string
Types []string
EmailSend []string
RedisConfig []string
MysqlTable string
ReplicationSecond time.Duration
//Путь к файлу с конфигами
config_file string = "/home/v-smerti/localhost/api/src/microService/config/log.json"
)

func init() {
print(«Starting…»)
//Спарсим конфиг
bs, err := ioutil.ReadFile(config_file)
if err != nil {
log.Panicln(err)
}

b := []byte(bs)
var conf Config
err = json.Unmarshal(b, &conf)
if err != nil {
log.Panicln(err)
}
//Передаём данные с конфиг файла в глобальные переменные
MailConf = map[string]string{
«username»: conf.MailConf[0],
«password»: conf.MailConf[1],
«host»: conf.MailConf[2],
«port»: conf.MailConf[3],
}

MailTo = conf.MailTo
Types = conf.Types
EmailSend = conf.EmailSend
RedisConfig = conf.Redis
MysqlTable = conf.MysqlTable
ReplicationSecond = conf.ReplicationTimeSecond

//Конект с редисом
R = redis.NewClient(&redis.Options{
Addr: RedisConfig[0],
Password: RedisConfig[1],
DB: 0,
})

//конект с бд
db, err := sql.Open(«mysql», conf.MysqlConnect[0]+":"+conf.MysqlConnect[1]+"@/"+conf.MysqlConnect[2])
if err != nil {
log.Fatal(err)
}
DB = db

//Инициализация пакета. Здесь проверям есть ли в редисе такие типы логов. Если нет то создаём
for _, typ := range Types {
_, err := R.Get(RedisConfig[2] + typ).Result()
if err == redis.Nil {
if err := R.Set(RedisConfig[2]+typ, " ", 0).Err(); err != nil {
mail.Send(MailConf, MailTo, «Fatal error game», «package GeneralsLog func Init____R.Set (Создание пустой записи в редис ключ „+typ+“)»)
}
} else if err != nil {
mail.Send(MailConf, MailTo, «Fatal error game», «package GeneralsLog func Init____R.Set (Проверка записи „+typ+“ в редисе)»)
}
}
print(" Ok!")
}

func main() {
for {
replication_db()
time.Sleep(time.Second * ReplicationSecond)
}
}

func replication_db() {

for _, typ := range Types {
data, err := R.Get(RedisConfig[2] + typ).Result()
if err == redis.Nil {

mail.Send(MailConf, MailTo, «Fatal error game», «package GeneralsLog func replication_db____R.Set (Нету в редисе „+typ+“)»)
if err := R.Set(RedisConfig[2]+typ, " ", 0).Err(); err != nil {
mail.Send(MailConf, MailTo, «Fatal error game», «package GeneralsLog func replication_db____R.Set (Создание пустой записи в редис ключ „+typ+“)»)
}
} else if err != nil {
log.Fatal(err)
mail.Send(MailConf, MailTo, «Fatal error game», «package GeneralsLog func replication_db____R.GET (Фатальная ошибка редиса)»)

} else {
if data != " " {
_, err := DB.Exec(«INSERT INTO » + MysqlTable + " (type,time,messages) VALUES" + strings.TrimRight(data, ","))
if err != nil {
log.Fatal(err)
} else {
log.Println(«replication»)
}
if err := R.Set(RedisConfig[2]+typ, " ", 0).Err(); err != nil {
mail.Send(MailConf, MailTo, «Fatal error game», «package GeneralsLog func replication_db____R.Set (Очистка записии „+typ+“)»)
}
}

}
}
}

package mail  import ( 	"fmt" 	"net/smtp" )  func Send(conf map[string]string, to []string, subject string, msg string) error { 	auth := smtp.PlainAuth( 		"", 		conf["username"], 		conf["password"], 		conf["host"], 	) 	address := fmt.Sprintf("%v:%v", conf["host"], conf["port"]) 	body := []byte("Subject: " + subject + "\r\n\r\n" + msg) 	err := smtp.SendMail( 		address, 		auth, 		conf["username"], 		to, 		body, 	) 	if err != nil { 		return err 	} 	return nil }