data

README

Data

Documentation

Index

• Variables
• func NewAccountClient(r registry.Discovery) accountv1.AccountClient
• func NewDiscovery(conf *conf.Registry) registry.Discovery
• func NewHistoryJobRepo(data *JobData, logger log.Logger) biz.HistoryJobRepo
• func NewHistoryRepo(data *Data, logger log.Logger) biz.HistoryRepo
• func NewHouseClient(r registry.Discovery) housev1.HouseClient
• func NewKafkaConsumeGroup(c *conf.Data) (sarama.ConsumerGroup, error)
• func NewKafkaProducer(conf *conf.Data) sarama.AsyncProducer
• func NewRegistrar(conf *conf.Registry) registry.Registrar
• type Data
  • func NewData(kp sarama.AsyncProducer, c *conf.Data, h1 housev1.HouseClient, ...) (*Data, func(), error)
• type HistoryMessage
• type JobData
  • func NewJobData(c *conf.Data, logger log.Logger) (*JobData, func(), error)

Variables

var JobProviderSet = wire.NewSet(NewJobData, NewKafkaConsumeGroup, NewHistoryJobRepo)

var ProviderSet = wire.NewSet(NewData, NewHistoryRepo, NewKafkaProducer,
	NewHouseClient, NewAccountClient, NewDiscovery, NewRegistrar)

ProviderSet is data providers.

Functions

func NewAccountClient

func NewAccountClient(r registry.Discovery) accountv1.AccountClient

func NewDiscovery

func NewDiscovery(conf *conf.Registry) registry.Discovery

func NewHistoryJobRepo

func NewHistoryJobRepo(data *JobData, logger log.Logger) biz.HistoryJobRepo

func NewHistoryRepo

func NewHistoryRepo(data *Data, logger log.Logger) biz.HistoryRepo

NewHistoryRepo .

func NewHouseClient

func NewHouseClient(r registry.Discovery) housev1.HouseClient

func NewKafkaConsumeGroup

func NewKafkaConsumeGroup(c *conf.Data) (sarama.ConsumerGroup, error)

func NewKafkaProducer

func NewKafkaProducer(conf *conf.Data) sarama.AsyncProducer

func NewRegistrar

func NewRegistrar(conf *conf.Registry) registry.Registrar

Types

type Data

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

Data .

func NewData

func NewData(kp sarama.AsyncProducer, c *conf.Data, h1 housev1.HouseClient,
	a1 accountv1.AccountClient, logger log.Logger) (*Data, func(), error)

NewData .

type HistoryMessage

type HistoryMessage struct{}

type JobData

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

func NewJobData

func NewJobData(c *conf.Data, logger log.Logger) (*JobData, func(), error)