|
@@ -40,7 +40,7 @@ func NewWire(viperViper *viper.Viper, logger *log.Logger) (*app.App, func(), err
|
|
|
database := repository.NewMongoDB(qmgoClient, viperViper)
|
|
|
rabbitMQ, cleanup := repository.NewRabbitMQ(viperViper, logger)
|
|
|
syncedEnforcer := repository.NewCasbinEnforcer(viperViper, logger, db)
|
|
|
- shardingManager := repository.NewShardingManager(logger)
|
|
|
+ shardingManager := repository.NewShardingManager(logger, viperViper)
|
|
|
repositoryRepository := repository.NewRepository(logger, db, client, qmgoClient, database, rabbitMQ, syncedEnforcer, shardingManager)
|
|
|
transaction := repository.NewTransaction(repositoryRepository)
|
|
|
sidSid := sid.NewSid()
|