api

Documentation

Overview

*

*
* @author liangjf
* @create on 2020/6/4
* @version 1.0

Index

• func CloseRpcClient()
• func GetMessageRpcClient() pb.MessageClient
• func InitMessageClientRpc(ctx context.Context, etcdAddr []string, serviceName string) error
• func ReBalanceMessageRpcClient() error

Functions

func CloseRpcClient

func CloseRpcClient()

CloseRpcClient release message rpc client

func GetMessageRpcClient

func GetMessageRpcClient() pb.MessageClient

GetMessageRpcClient get message rpc client

func InitMessageClientRpc

func InitMessageClientRpc(ctx context.Context, etcdAddr []string, serviceName string) error

func ReBalanceMessageRpcClient

func ReBalanceMessageRpcClient() error

ReBalanceMessageRpcClient balance message rpc client