LiquidDB

package

v1.4.1 Latest Latest Go to latest Published: Mar 15, 2024 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cesnow/liquid-engine

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL