db

Documentation

Index

• Constants
• type CachePipel
• type MongoConf
  • func (mc *MongoConf) GetDb() string
  • 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
• type RedisClient
• type RedisConf
  • func (rc *RedisConf) GetDB(dbname string) int
  • func (rc *RedisConf) NewRedisClientDB(ctx context.Context, db int) (RedisClient, error)
• type RedisDI

Constants

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

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

Types

type CachePipel

type CachePipel interface {
	Get(key string) *redis.StringCmd
	Exec() ([]redis.Cmder, error)
}

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) GetDb

func (mc *MongoConf) GetDb() string

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
	GetDb() string
}

type RedisClient

type RedisClient interface {
	Close() error
	Ping() string
	CountKeys() (int, error)
	Get(k string) ([]byte, error)
	Set(k string, v interface{}, exp time.Duration) (string, error)
	Del(k string) (int64, error)
	LPush(k string, v interface{}) (int64, error)
	RPop(k string) ([]byte, error)
	HGet(key string, field string) string
	HSet(key string, values map[string]string) error
	HGetAll(key string) map[string]string
	Exists(key string) bool
	Expired(key string, d time.Duration) (bool, error)
	NewPiple() CachePipel
	Keys(pattern string) ([]string, error)
}

type RedisConf

type RedisConf struct {
	Host  string         `yaml:"host"`
	Pwd   string         `yaml:"pass"`
	DbMap map[string]int `yaml:"dbMap"`
}

func (*RedisConf) GetDB

func (rc *RedisConf) GetDB(dbname string) int

func (*RedisConf) NewRedisClientDB

func (rc *RedisConf) NewRedisClientDB(ctx context.Context, db int) (RedisClient, error)

type RedisDI

type RedisDI interface {
	NewRedisClientDB(ctx context.Context, db int) (RedisClient, error)
	GetDB(dbname string) int
}