db

Documentation

Index

• Constants
• type MongoConf
  • func (mc *MongoConf) GetUri() string
  • func (mc *MongoConf) NewMongoDBClient(ctx context.Context, userDB string) (MongoDBClient, error)
  • func (mc *MongoConf) SetAuth(user, pwd string)
• type MongoDBClient
  • func GetMgoDBClientByCtx(ctx context.Context) MongoDBClient
  • func GetMgoDBClientByGin(c *gin.Context) MongoDBClient
  • func GetMgoDBClientByReq(req *http.Request) MongoDBClient
• type MongoDI

Constants

const (
	CtxMongoKey = util.CtxKey("ctxMongoKey")
	HeaderDBKey = "raccMongoDB"
)

const (
	CoreDB = "core"
	UserDB = "user"
)

Types

type MongoConf

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

func (*MongoConf) GetUri

func (mc *MongoConf) GetUri() string

func (*MongoConf) NewMongoDBClient

func (mc *MongoConf) NewMongoDBClient(ctx context.Context, userDB string) (MongoDBClient, error)

func (*MongoConf) SetAuth

func (mc *MongoConf) SetAuth(user, pwd string)

type MongoDBClient

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

func GetMgoDBClientByCtx

func GetMgoDBClientByCtx(ctx context.Context) MongoDBClient

func GetMgoDBClientByGin

func GetMgoDBClientByGin(c *gin.Context) MongoDBClient

func GetMgoDBClientByReq

func GetMgoDBClientByReq(req *http.Request) MongoDBClient

type MongoDI

type MongoDI interface {
	NewMongoDBClient(ctx context.Context, userDB string) (MongoDBClient, error)
	SetAuth(user, pwd string)
	GetUri() string
}