openbilibili/app/interface/main/mcn/dao/global/resource.go

package global

import (
	"go-common/app/interface/main/mcn/conf"
	taggrpc "go-common/app/interface/main/tag/api"
	accgrpc "go-common/app/service/main/account/api"
	arcgrpc "go-common/app/service/main/archive/api"
	memgrpc "go-common/app/service/main/member/api"
	"go-common/library/cache/memcache"
	bm "go-common/library/net/http/blademaster"

	"github.com/pkg/errors"
)

var (
	accGRPC accgrpc.AccountClient
	memGRPC memgrpc.MemberClient
	arcGRPC arcgrpc.ArchiveClient
	tagGRPC taggrpc.TagRPCClient

	mc *memcache.Pool

	bmClient *bm.Client
)

// GetAccGRPC .
func GetAccGRPC() accgrpc.AccountClient {
	return accGRPC
}

// GetMemGRPC .
func GetMemGRPC() memgrpc.MemberClient {
	return memGRPC
}

// GetArcGRPC .
func GetArcGRPC() arcgrpc.ArchiveClient {
	return arcGRPC
}

// GetTagGRPC .
func GetTagGRPC() taggrpc.TagRPCClient {
	return tagGRPC
}

// GetMc get mc
func GetMc() *memcache.Pool {
	return mc
}

// GetBMClient get http client
func GetBMClient() *bm.Client {
	return bmClient
}

//Init init global
func Init(c *conf.Config) {
	var err error
	if accGRPC, err = accgrpc.NewClient(c.GRPCClient.Account); err != nil {
		panic(errors.WithMessage(err, "Failed to dial account service"))
	}
	if memGRPC, err = memgrpc.NewClient(c.GRPCClient.Member); err != nil {
		panic(errors.WithMessage(err, "Failed to dial member service"))
	}
	if arcGRPC, err = arcgrpc.NewClient(c.GRPCClient.Archive); err != nil {
		panic(errors.WithMessage(err, "Failed to dial archive service"))
	}
	if tagGRPC, err = taggrpc.NewClient(c.GRPCClient.Tag); err != nil {
		panic(errors.WithMessage(err, "Failed to dial tag service"))
	}

	mc = memcache.NewPool(&c.Memcache.Config)
	bmClient = bm.NewClient(c.HTTPClient)
}