data

README

Data

Documentation

Index

• Variables
• func NewAccountRepo(data *Data, logger log.Logger) biz.AccountRepo
• func NewAccountServiceClient(r registry.Discovery, tp *tracesdk.TracerProvider) accountv1.AccountClient
• func NewApiRepo(data *Data, logger log.Logger) biz.ApiRepo
• func NewCasbinAdapter(data *Data, logger log.Logger) persist.Adapter
• func NewCasbinEnforcer(c *conf.Casbin, adapter persist.Adapter) (*casbin.SyncedEnforcer, func(), error)
• func NewDB() *sql.DB
• func NewDictDataRepo(data *Data, logger log.Logger) biz.DictDataRepo
• func NewDictTypeRepo(data *Data, logger log.Logger) biz.DictTypeRepo
• func NewDiscovery(conf *conf.Registry) registry.Discovery
• func NewEnforcer(c *conf.Data) *casbin.Enforcer
• func NewEntAdapter(db *sql.DB) *entadapter.Adapter
• func NewEntClient(conf *conf.Data, logger log.Logger) *ent.Client
• func NewKafkaConsumer(conf *conf.Data) sarama.Consumer
• func NewKafkaProducer(conf *conf.Data) sarama.AsyncProducer
• func NewRedisClient(c *conf.Data, logger log.Logger) *redis.Client
• func NewRegistrar(conf *conf.Registry) registry.Registrar
• func NewRoleRepo(data *Data, logger log.Logger) biz.RoleRepo
• func NewUserRepo(data *Data, logger log.Logger) biz.UserRepo
• type Data
  • func NewData(logger log.Logger, entClient *ent.Client, redisClient *redis.Client, ...) (*Data, func(), error)

Variables

var ProviderSet = wire.NewSet(
	NewData, NewEntClient, NewRedisClient,
	NewKafkaProducer, NewKafkaConsumer,
	NewDiscovery, NewRegistrar,
	NewEnforcer,
	NewUserRepo, NewRoleRepo, NewDictDataRepo,
	NewAccountServiceClient, NewAccountRepo,
)

ProviderSet is data providers.

Functions

func NewAccountRepo

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

func NewAccountServiceClient

func NewAccountServiceClient(r registry.Discovery, tp *tracesdk.TracerProvider) accountv1.AccountClient

func NewApiRepo

func NewApiRepo(data *Data, logger log.Logger) biz.ApiRepo

func NewCasbinAdapter

func NewCasbinAdapter(data *Data, logger log.Logger) persist.Adapter

func NewCasbinEnforcer

func NewCasbinEnforcer(c *conf.Casbin, adapter persist.Adapter) (*casbin.SyncedEnforcer, func(), error)

func NewDB

func NewDB() *sql.DB

func NewDictDataRepo

func NewDictDataRepo(data *Data, logger log.Logger) biz.DictDataRepo

func NewDictTypeRepo

func NewDictTypeRepo(data *Data, logger log.Logger) biz.DictTypeRepo

func NewDiscovery

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

func NewEnforcer

func NewEnforcer(c *conf.Data) *casbin.Enforcer

func NewEntAdapter

func NewEntAdapter(db *sql.DB) *entadapter.Adapter

func NewEntClient

func NewEntClient(conf *conf.Data, logger log.Logger) *ent.Client

func NewKafkaConsumer

func NewKafkaConsumer(conf *conf.Data) sarama.Consumer

func NewKafkaProducer

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

func NewRedisClient

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

func NewRegistrar

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

func NewRoleRepo

func NewRoleRepo(data *Data, logger log.Logger) biz.RoleRepo

func NewUserRepo

func NewUserRepo(data *Data, logger log.Logger) biz.UserRepo

Types

type Data

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

Data .

func NewData

func NewData(logger log.Logger,
	entClient *ent.Client, redisClient *redis.Client,
	enforcer *casbin.Enforcer,
	producer sarama.AsyncProducer, consumer sarama.Consumer,
	ac accountv1.AccountClient,
) (*Data, func(), error)

NewData .