data

Documentation

Index

• Variables
• func NewAccountRepo(data *Data, logger log.Logger) biz.AccountRepo
• func NewHiveConn(conf *conf.Data, logger log.Logger) *gohive.Connection
• func NewKafkaClient(conf *conf.Data, logger log.Logger) sarama.Client
• func NewRealWorldGrpcConn(ctx context.Context, confServer *conf.Server, logger log.Logger) (*grpc.ClientConn, error)
• func NewRedisConn(conf *conf.Data, logger log.Logger) *redis.Client
• type Data
  • func NewData(c *conf.Data, logger log.Logger, redisCli *redis.Client, ...) (*Data, func(), error)

Variables

var ProviderSet = wire.NewSet(
	NewData,
	NewRedisConn,
	NewHiveConn,
	NewKafkaClient,
	NewRealWorldGrpcConn,

	NewAccountRepo,
)

ProviderSet is data providers.

Functions

func NewAccountRepo

func NewAccountRepo(data *Data, logger log.Logger) biz.AccountRepo

func NewHiveConn

func NewHiveConn(conf *conf.Data, logger log.Logger) *gohive.Connection

NewHiveConn .

func NewKafkaClient

func NewKafkaClient(conf *conf.Data, logger log.Logger) sarama.Client

NewKafkaClient . link: https://www.jianshu.com/p/666d2604e8f8

func NewRealWorldGrpcConn

func NewRealWorldGrpcConn(ctx context.Context, confServer *conf.Server, logger log.Logger) (*grpc.ClientConn, error)

func NewRedisConn

func NewRedisConn(conf *conf.Data, logger log.Logger) *redis.Client

NewRedisConn .

Types

type Data

type Data struct {
	// contains filtered or unexported fields
}

Data .

func NewData

func NewData(
	c *conf.Data,
	logger log.Logger,
	redisCli *redis.Client,
	hiveConn *gohive.Connection,
	kafkaCli sarama.Client,
	realWorldGrpcConn *grpc.ClientConn,
) (*Data, func(), error)

NewData .