client

Documentation

Index

• Constants
• func GetConn() (*kafukago.Conn, error)
• func GetNewReader(topic string, groupID string) *kafukago.Reader
• func GetNewWriter(topic string, async bool) (*kafukago.Writer, error)
• func GetRocketmqAdmin() (admin.Admin, string)
• func GetRocketmqProducer() rocketmq.Producer
• func GetRocketmqPushConsumer(group string) rocketmq.PushConsumer
• func InitCartRPC() (*cartservice.Client, error)
• func InitCommodityRPC() (*commodityservice.Client, error)
• func InitCommodityStreamClientRPC() (*commodityservice.StreamClient, error)
• func InitMySQL() (db *gorm.DB, err error)
• func InitOrderRPC() (*orderservice.Client, error)
• func InitPaymentRPC() (*paymentservice.Client, error)
• func InitRedis(db int) (*redis.Client, error)
• func InitUserRPC() (*userservice.Client, error)
• func IsESConnected(es *elasticsearch.Client) bool
• func NewEsClient() (*elasticsearch.Client, error)
• func NewEsCommodityClient() (*elastic.Client, error)
• func NewRedisClient(db int) (*redis.Client, error)

Constants

const (
	Timeout = 3 * time.Second // 默认超时时间
)

Functions

func GetConn

func GetConn() (*kafukago.Conn, error)

GetConn conn不能保证并发安全,仅可作为单线程的长连接使用。

func GetNewReader

func GetNewReader(topic string, groupID string) *kafukago.Reader

GetNewReader 创建一个reader示例，reader是并发安全的

func GetNewWriter

func GetNewWriter(topic string, async bool) (*kafukago.Writer, error)

GetNewWriter 创建一个writer示例，writer是并发安全的。

func GetRocketmqAdmin

func GetRocketmqAdmin() (admin.Admin, string)

GetRocketmqAdmin 获取一个 admin 实例以及 brokerAddr

func GetRocketmqProducer

func GetRocketmqProducer() rocketmq.Producer

GetRocketmqProducer 获取一个 producer 实例

func GetRocketmqPushConsumer

func GetRocketmqPushConsumer(group string) rocketmq.PushConsumer

GetRocketmqPushConsumer 获取一个 push consumer 实例

func InitCartRPC

func InitCartRPC() (*cartservice.Client, error)

func InitCommodityRPC

func InitCommodityRPC() (*commodityservice.Client, error)

func InitCommodityStreamClientRPC

func InitCommodityStreamClientRPC() (*commodityservice.StreamClient, error)

func InitMySQL

func InitMySQL() (db *gorm.DB, err error)

InitMySQL 通用初始化mysql函数，传入tableName指定表

func InitOrderRPC

func InitOrderRPC() (*orderservice.Client, error)

func InitPaymentRPC

func InitPaymentRPC() (*paymentservice.Client, error)

func InitRedis

func InitRedis(db int) (*redis.Client, error)

func InitUserRPC

func InitUserRPC() (*userservice.Client, error)

func IsESConnected

func IsESConnected(es *elasticsearch.Client) bool

func NewEsClient

func NewEsClient() (*elasticsearch.Client, error)

func NewEsCommodityClient

func NewEsCommodityClient() (*elastic.Client, error)

func NewRedisClient

func NewRedisClient(db int) (*redis.Client, error)

NewRedisClient 传入dbName，具体参考 constants 包