ossService/config/config.go

package config

import (
	"app.yhyue.com/moapp/jybase/es"
	"app.yhyue.com/moapp/jybase/go-xweb/log"
	. "app.yhyue.com/moapp/jybase/mongodb"
	"github.com/go-redis/redis/v8"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/os/gctx"
)

// OSSAccount 表示OSS帐号信息
type OSSAccount struct {
	ID              string `json:"id"`
	Endpoint        string `json:"endpoint"`
	AccessKeyId     string `json:"access_key_id"`
	AccessKeySecret string `json:"access_key_secret"`
}

// BucketInfo 表示bucket维表数据
type BucketInfo struct {
	BucketID   string `json:"bucket_id"`
	AccountID  string `json:"account_id"`
	BucketName string `json:"bucket_name"`
}

type PushMail struct {
	Addr         string `json:"addr"`
	Port         int    `json:"port"`
	Pwd          string `json:"pwd"`
	User         string `json:"user"`
	MailPoolSize int    `json:"mailPoolSize"`
	MailReTry    int    `json:"mailReTry"`
}

var Rdb *redis.Client
var Mgo *MongodbSim

// LoadConfig 从指定的配置文件中加载配置
func init() {
	log.Println("开始初始化。。。")
	ctx := gctx.New()
	es.NewEs(g.Config().MustGet(ctx, "elasticSearch.version").String(), g.Config().MustGet(ctx, "elasticSearch.address").String(), g.Config().MustGet(ctx, "elasticSearch.size").Int(), g.Config().MustGet(ctx, "elasticSearch.userName").String(), g.Config().MustGet(ctx, "elasticSearch.password").String())
	log.Println("初始化elasticSearch结束。。。")
	Rdb = redis.NewClient(&redis.Options{
		Addr:     g.Config().MustGet(ctx, "redis.address").String(),
		Password: g.Config().MustGet(ctx, "redis.password").String(),
		DB:       0,
	})
	log.Println("初始化redis结束。。。")
	Mgo = &MongodbSim{
		MongodbAddr: g.Config().MustGet(ctx, "mongodb.address").String(),
		Size:        g.Config().MustGet(ctx, "mongodb.size").Int(),
		DbName:      g.Config().MustGet(ctx, "mongodb.dbName").String(),
		UserName:    g.Config().MustGet(ctx, "mongodb.userName").String(),
		Password:    g.Config().MustGet(ctx, "mongodb.password").String(),
	}
	Mgo.InitPool()
	log.Println("初始化mongodb结束。。。")
}