Database

Documentation

Index

• type CacheDB
  • func ConnectWithCacheDB(config *Settings.CacheDbConf) (*CacheDB, error)
  • func (r *CacheDB) Delete(key string) (bool, error)
  • func (r *CacheDB) Exists(key string) bool
  • func (r *CacheDB) Get(key string) ([]byte, error)
  • func (r *CacheDB) GetClient() redis.Conn
  • func (r *CacheDB) LikeDeletes(key string) error
  • func (r *CacheDB) SetString(key string, data string, time int) error
• type DocDB
  • func ConnectWithDocDB(config *Settings.DocDbConf) (*DocDB, error)
  • func (db *DocDB) Database(dbname string) *mongo.Database
  • func (db *DocDB) GetClient() *mongo.Client
  • func (db *DocDB) ListIndexes(database, collection string)
  • func (db *DocDB) PopulateIndex(database, collection, key string, sort int32, unique bool)
  • func (db *DocDB) PopulateMultiIndex(database, collection string, keys []string, sorts []int32, unique bool)
  • func (db *DocDB) PopulateTTLIndex(database, collection, key string, sort int32, unique bool, ttl int32)
• type IDatabase
• type RDB
  • func ConnectWithRDB(conf *Settings.RDBConf) (rdb *RDB, err error)
  • func (rdb *RDB) GetClient(dbName string) (*gorm.DB, error)

Types

type CacheDB

type CacheDB struct {
	IDatabase
	// contains filtered or unexported fields
}

func ConnectWithCacheDB

func ConnectWithCacheDB(config *Settings.CacheDbConf) (*CacheDB, error)

func (*CacheDB) Delete

func (r *CacheDB) Delete(key string) (bool, error)

func (*CacheDB) Exists

func (r *CacheDB) Exists(key string) bool

func (*CacheDB) Get

func (r *CacheDB) Get(key string) ([]byte, error)

func (*CacheDB) GetClient

func (r *CacheDB) GetClient() redis.Conn

func (*CacheDB) LikeDeletes

func (r *CacheDB) LikeDeletes(key string) error

func (*CacheDB) SetString

func (r *CacheDB) SetString(key string, data string, time int) error

type DocDB

type DocDB struct {
	IDatabase
	// contains filtered or unexported fields
}

func ConnectWithDocDB

func ConnectWithDocDB(config *Settings.DocDbConf) (*DocDB, error)

func (*DocDB) Database

func (db *DocDB) Database(dbname string) *mongo.Database

func (*DocDB) GetClient

func (db *DocDB) GetClient() *mongo.Client

func (*DocDB) ListIndexes

func (db *DocDB) ListIndexes(database, collection string)

func (*DocDB) PopulateIndex

func (db *DocDB) PopulateIndex(database, collection, key string, sort int32, unique bool)

func (*DocDB) PopulateMultiIndex

func (db *DocDB) PopulateMultiIndex(database, collection string, keys []string, sorts []int32, unique bool)

func (*DocDB) PopulateTTLIndex

func (db *DocDB) PopulateTTLIndex(database, collection, key string, sort int32, unique bool, ttl int32)

type IDatabase

type IDatabase interface {
	GetClient()
	// contains filtered or unexported methods
}

type RDB

type RDB struct {
	IDatabase
	// contains filtered or unexported fields
}

func ConnectWithRDB

func ConnectWithRDB(conf *Settings.RDBConf) (rdb *RDB, err error)

func (*RDB) GetClient

func (rdb *RDB) GetClient(dbName string) (*gorm.DB, error)