resource

Documentation

Index

• Variables
• func CreateGrpcClientConn(addr string, maxRetryCount uint, timeout time.Duration) (*grpc.ClientConn, error)
• func InitBrokerHub()
• func InitBrokerResource()
• func InitLogicChan()
• func InitLogicResource()
• func InitMySQL()

Variables

var (
	WaitToBrokerDialogueChan chan *pb.PushDialogue
	WaitToBrokerSignalChan   chan *pb.PushSignal
)

var (
	LogicClient pb.LogicDealerClient
	Hub         *model.BizHub
)

------broker-------

var (
	BrokerHub *model.BrokerHub
)

var (
	MySQLClient *gorm.DB
)

-------logic-------

Functions

func CreateGrpcClientConn

func CreateGrpcClientConn(addr string, maxRetryCount uint, timeout time.Duration) (*grpc.ClientConn, error)

func InitBrokerHub

func InitBrokerHub()

func InitBrokerResource

func InitBrokerResource()

func InitLogicChan

func InitLogicChan()

func InitLogicResource

func InitLogicResource()

func InitMySQL

func InitMySQL()