Documentation
¶
Overview ¶
*
* * @author liangjf * @create on 2020/6/3 * @version 1.0
*
* * @author liangjf * @create on 2020/6/3 * @version 1.0
*
* * @author liangjf * @create on 2020/6/3 * @version 1.0
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoThisGatewayNode = errors.New("no this gateway node")
)
Functions ¶
func CLoseRpcClient ¶
func CLoseRpcClient()
func GetGatewayRpcClient ¶
func GetGatewayRpcClient(host string) (pb.GatewayClient, error)
func InitGatewayRpcClient ¶
func StopKafkaConsumer ¶
func StopKafkaConsumer()
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.