service

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

• Variables
• func CLoseRpcClient()
• func GetGatewayRpcClient(host string) (pb.GatewayClient, error)
• func InitGatewayRpcClient(etcdAddr []string) error
• func InitKafkaConsumer(ctx context.Context, brokerAddr []string) error
• func StopKafkaConsumer()

Variables

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 InitGatewayRpcClient(etcdAddr []string) error

func InitKafkaConsumer

func InitKafkaConsumer(ctx context.Context, brokerAddr []string) error

func StopKafkaConsumer

func StopKafkaConsumer()