LiquidDB

Documentation

Index

• func EnsureLiquidAdminIndexes()
• func EnsureLiquidMemberIndexes()
• func EnsureLiquidUserIndexes()
• func GetCacheDb() *database.CacheDB
• func GetDocColl(collection string) *mongo.Collection
• func GetDocCollWithDb(dbName, collection string) *mongo.Collection
• func GetDocDb() *database.DocDB
• func GetLiquidAdminCol() *mongo.Collection
• func GetLiquidMemberCol() *mongo.Collection
• func GetLiquidUserCol() *mongo.Collection
• func GetLiquidUserDataCol() *mongo.Collection
• func GetMsgQueueV0() *MsgQueue.AMQPv0
• func GetMsgQueueV1() *MsgQueue.AMQPv1
• func GetRdb() *database.RDB
• type LiquidDB
  • func GetInstance() *LiquidDB
  • func (db *LiquidDB) ConnectCacheDbService(config *settings.CacheDbConf)
  • func (db *LiquidDB) ConnectDocDbService(config *settings.DocDbConf)
  • func (db *LiquidDB) ConnectMsgQueueService(config *settings.AMQPConf)
  • func (db *LiquidDB) ConnectRDbService(config *settings.RDBConf)
  • func (db *LiquidDB) EnsureLiquidAdminIndexes()
  • func (db *LiquidDB) EnsureLiquidMemberIndexes()
  • func (db *LiquidDB) EnsureLiquidUserIndexes()
  • func (db *LiquidDB) GetCacheDb() *database.CacheDB
  • func (db *LiquidDB) GetDocColl(collection string) *mongo.Collection
  • func (db *LiquidDB) GetDocCollWithDb(dbName, collection string) *mongo.Collection
  • func (db *LiquidDB) GetDocDb() *database.DocDB
  • func (db *LiquidDB) GetLiquidAdminCol() *mongo.Collection
  • func (db *LiquidDB) GetLiquidMemberCol() *mongo.Collection
  • func (db *LiquidDB) GetLiquidUserCol() *mongo.Collection
  • func (db *LiquidDB) GetLiquidUserDataCol() *mongo.Collection
  • func (db *LiquidDB) GetMsgQueueV0() *MsgQueue.AMQPv0
  • func (db *LiquidDB) GetMsgQueueV1() *MsgQueue.AMQPv1
  • func (db *LiquidDB) GetRdb() *database.RDB
  • func (db *LiquidDB) InitializeSystemDocIndexes()
  • func (db *LiquidDB) SetCodeName(codename string)

Functions

func EnsureLiquidAdminIndexes

func EnsureLiquidAdminIndexes()

func EnsureLiquidMemberIndexes

func EnsureLiquidMemberIndexes()

func EnsureLiquidUserIndexes

func EnsureLiquidUserIndexes()

func GetCacheDb

func GetCacheDb() *database.CacheDB

func GetDocColl

func GetDocColl(collection string) *mongo.Collection

func GetDocCollWithDb

func GetDocCollWithDb(dbName, collection string) *mongo.Collection

func GetDocDb

func GetDocDb() *database.DocDB

func GetLiquidAdminCol

func GetLiquidAdminCol() *mongo.Collection

func GetLiquidMemberCol

func GetLiquidMemberCol() *mongo.Collection

func GetLiquidUserCol

func GetLiquidUserCol() *mongo.Collection

func GetLiquidUserDataCol

func GetLiquidUserDataCol() *mongo.Collection

func GetMsgQueueV0

func GetMsgQueueV0() *MsgQueue.AMQPv0

func GetMsgQueueV1

func GetMsgQueueV1() *MsgQueue.AMQPv1

func GetRdb

func GetRdb() *database.RDB

Types

type LiquidDB

type LiquidDB struct {
	CodeName string
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *LiquidDB

func (*LiquidDB) ConnectCacheDbService

func (db *LiquidDB) ConnectCacheDbService(config *settings.CacheDbConf)

func (*LiquidDB) ConnectDocDbService

func (db *LiquidDB) ConnectDocDbService(config *settings.DocDbConf)

func (*LiquidDB) ConnectMsgQueueService

func (db *LiquidDB) ConnectMsgQueueService(config *settings.AMQPConf)

func (*LiquidDB) ConnectRDbService

func (db *LiquidDB) ConnectRDbService(config *settings.RDBConf)

func (*LiquidDB) EnsureLiquidAdminIndexes

func (db *LiquidDB) EnsureLiquidAdminIndexes()

func (*LiquidDB) EnsureLiquidMemberIndexes

func (db *LiquidDB) EnsureLiquidMemberIndexes()

func (*LiquidDB) EnsureLiquidUserIndexes

func (db *LiquidDB) EnsureLiquidUserIndexes()

func (*LiquidDB) GetCacheDb

func (db *LiquidDB) GetCacheDb() *database.CacheDB

func (*LiquidDB) GetDocColl

func (db *LiquidDB) GetDocColl(collection string) *mongo.Collection

func (*LiquidDB) GetDocCollWithDb

func (db *LiquidDB) GetDocCollWithDb(dbName, collection string) *mongo.Collection

func (*LiquidDB) GetDocDb

func (db *LiquidDB) GetDocDb() *database.DocDB

func (*LiquidDB) GetLiquidAdminCol

func (db *LiquidDB) GetLiquidAdminCol() *mongo.Collection

func (*LiquidDB) GetLiquidMemberCol

func (db *LiquidDB) GetLiquidMemberCol() *mongo.Collection

func (*LiquidDB) GetLiquidUserCol

func (db *LiquidDB) GetLiquidUserCol() *mongo.Collection

func (*LiquidDB) GetLiquidUserDataCol

func (db *LiquidDB) GetLiquidUserDataCol() *mongo.Collection

func (*LiquidDB) GetMsgQueueV0

func (db *LiquidDB) GetMsgQueueV0() *MsgQueue.AMQPv0

func (*LiquidDB) GetMsgQueueV1

func (db *LiquidDB) GetMsgQueueV1() *MsgQueue.AMQPv1

func (*LiquidDB) GetRdb

func (db *LiquidDB) GetRdb() *database.RDB

func (*LiquidDB) InitializeSystemDocIndexes

func (db *LiquidDB) InitializeSystemDocIndexes()

func (*LiquidDB) SetCodeName

func (db *LiquidDB) SetCodeName(codename string)