data

README

Data

Documentation

Index

• Variables
• func NewKafkaProducer(conf *conf.Data) sarama.AsyncProducer
• func NewShippingRepo(data *Data, logger log.Logger) biz.ShippingRepo
• type Data
  • func NewData(producer sarama.AsyncProducer, conf *conf.Data, logger log.Logger) (*Data, func(), error)
• type ShippingEntry

Variables

var ProviderSet = wire.NewSet(NewData, NewKafkaProducer, NewShippingRepo)

ProviderSet is data providers.

Functions

func NewKafkaProducer

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

func NewShippingRepo

func NewShippingRepo(data *Data, logger log.Logger) biz.ShippingRepo

Types

type Data

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

Data .

func NewData

func NewData(producer sarama.AsyncProducer, conf *conf.Data, logger log.Logger) (*Data, func(), error)

NewData .

type ShippingEntry

type ShippingEntry struct {
	OrderId string `json:"order_id"`
}