jyMicroservices/jyBXSubscribe/api/init/logs.go

package init

import (
	"app.yhyue.com/moapp/jybase/mongodb"
	"jyBXSubscribe/api/internal/config"
	"jyBXSubscribe/entity"

	"log"
)

var SubscribeUpdateLog *entity.SaveLogs

func LogInit(sl *entity.SaveLogs, c config.SaveLogConfig, mgo mongodb.MongodbSim) {
	sl = entity.NewSaveLog(c.Name, c.CollName, c.MgoSaveCacheSize, c.SPSize, c.BulkSize, c.TimeAfter, c.Timeout, mgo)
	go sl.SaveMgo()
	log.Println("初始化日志保存")
}