conn

type MongoConf struct {
	Uri       string `yaml:"uri"`
	User      string `yaml:"user"`
	Pass      string `yaml:"pass"`
	DefaultDB string `yaml:"defaul"`
	// contains filtered or unexported fields
}

type MongoDBConn interface {
	GetDbConn() *mongo.Database
	WithSession(f func(sc mongo.SessionContext) error) error
	AbortTransaction(sc mongo.SessionContext) error
	CommitTransaction(sc mongo.SessionContext) error
	Close() error
	Ping() error
}

type MongoDI interface {
	NewDefaultDbConn(ctx context.Context) (MongoDBConn, error)
	NewDbConn(ctx context.Context, db string) (MongoDBConn, error)
	SetAuth(user, pwd string)
	GetUri() string
	GetDb() string
}

type MongoOptsDI interface {
	NewDefaultDbConnWithOpts(ctx context.Context) (MongoDBConn, error)
	NewDbConnWithOpts(ctx context.Context, db string) (MongoDBConn, error)
	SetAuth(user, pwd string)
	GetUri() string
	GetDb() string
}