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 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 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 包