mongo

Documentation

Index

• func LoadMongo(tag string, lo loggerInterfaces.Logger, ...) databaseInterfaces.Mongo
• type ModelEnc
• type Mongo
  • func (c *Mongo) Client() *mongo.Client
  • func (c *Mongo) GetConfig() databaseInterfaces.MongoProviderConfig
  • func (c *Mongo) Monitor() *event.CommandMonitor
  • func (c *Mongo) ODM() databaseInterfaces.MongoODM
  • func (c *Mongo) OnInitError(e error) (client *mongo.Client, err error)
  • func (c *Mongo) Start() (err error)
  • func (c *Mongo) UseEncryption(encLib encryptionInterfaces.Encryption) databaseInterfaces.Mongo
  • func (c *Mongo) WithMonitor(enable bool) databaseInterfaces.Mongo
• type ODM
  • func (c *ODM) Collection(model interface{}, name string) databaseInterfaces.MongoODM
  • func (c *ODM) Count(ctx context.Context) (res int64, err error)
  • func (c *ODM) Create(ctx context.Context, data interface{}) (cc *databaseInterfaces.MongoTransaction)
  • func (c *ODM) Delete(ctx context.Context) *databaseInterfaces.MongoTransaction
  • func (c *ODM) Drop(ctx context.Context) databaseInterfaces.MongoODM
  • func (c *ODM) Error() error
  • func (c *ODM) Filter(filter map[string]interface{}) databaseInterfaces.MongoODM
  • func (c *ODM) Find(ctx context.Context, dest interface{}) (cc *databaseInterfaces.MongoTransaction)
  • func (c *ODM) FindRaw(ctx context.Context) (results []bson.Raw, cc *databaseInterfaces.MongoTransaction)
  • func (c *ODM) Index() databaseInterfaces.MongoODM
  • func (c *ODM) NativeCollection() *mongo.Collection
  • func (c *ODM) SetLimit(limit int64) databaseInterfaces.MongoODM
  • func (c *ODM) SetSkip(skip int64) databaseInterfaces.MongoODM
  • func (c *ODM) SetSort(sortBy string, desc bool) databaseInterfaces.MongoODM
  • func (c *ODM) Update(ctx context.Context, data map[string]interface{}) *databaseInterfaces.MongoTransaction
  • func (c *ODM) Upsert(ctx context.Context, data interface{}, matchKey []string) (cc *databaseInterfaces.MongoTransaction)
• type Stores
  • func NewStore() *Stores
  • func (c *Stores) LoadClient(id string) (client *Mongo, ok bool)
  • func (c *Stores) LoadClientByTag(ta string) (client *Mongo, ok bool)
  • func (c *Stores) StoreClient(client *Mongo)

Functions

func LoadMongo

func LoadMongo(tag string, lo loggerInterfaces.Logger, config databaseInterfaces.MongoProviderConfig) databaseInterfaces.Mongo

Types

type ModelEnc

type ModelEnc struct {
	Encrypted bool
	Hash      bool
	Name      string
}

type Mongo

type Mongo struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Mongo) Client

func (c *Mongo) Client() *mongo.Client

func (*Mongo) GetConfig

func (c *Mongo) GetConfig() databaseInterfaces.MongoProviderConfig

func (*Mongo) Monitor

func (c *Mongo) Monitor() *event.CommandMonitor

func (*Mongo) ODM

func (c *Mongo) ODM() databaseInterfaces.MongoODM

func (*Mongo) OnInitError

func (c *Mongo) OnInitError(e error) (client *mongo.Client, err error)

func (*Mongo) Start

func (c *Mongo) Start() (err error)

func (*Mongo) UseEncryption

func (c *Mongo) UseEncryption(encLib encryptionInterfaces.Encryption) databaseInterfaces.Mongo

func (*Mongo) WithMonitor

func (c *Mongo) WithMonitor(enable bool) databaseInterfaces.Mongo

type ODM

type ODM struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*ODM) Collection

func (c *ODM) Collection(model interface{}, name string) databaseInterfaces.MongoODM

func (*ODM) Count

func (c *ODM) Count(ctx context.Context) (res int64, err error)

func (*ODM) Create

func (c *ODM) Create(ctx context.Context, data interface{}) (cc *databaseInterfaces.MongoTransaction)

func (*ODM) Delete

func (c *ODM) Delete(ctx context.Context) *databaseInterfaces.MongoTransaction

func (*ODM) Drop

func (c *ODM) Drop(ctx context.Context) databaseInterfaces.MongoODM

func (*ODM) Error

func (c *ODM) Error() error

func (*ODM) Filter

func (c *ODM) Filter(filter map[string]interface{}) databaseInterfaces.MongoODM

func (*ODM) Find

func (c *ODM) Find(ctx context.Context, dest interface{}) (cc *databaseInterfaces.MongoTransaction)

func (*ODM) FindRaw

func (c *ODM) FindRaw(ctx context.Context) (results []bson.Raw, cc *databaseInterfaces.MongoTransaction)

func (*ODM) Index

func (c *ODM) Index() databaseInterfaces.MongoODM

func (*ODM) NativeCollection

func (c *ODM) NativeCollection() *mongo.Collection

func (*ODM) SetLimit

func (c *ODM) SetLimit(limit int64) databaseInterfaces.MongoODM

func (*ODM) SetSkip

func (c *ODM) SetSkip(skip int64) databaseInterfaces.MongoODM

func (*ODM) SetSort

func (c *ODM) SetSort(sortBy string, desc bool) databaseInterfaces.MongoODM

func (*ODM) Update

func (c *ODM) Update(ctx context.Context, data map[string]interface{}) *databaseInterfaces.MongoTransaction

func (*ODM) Upsert

func (c *ODM) Upsert(ctx context.Context, data interface{}, matchKey []string) (cc *databaseInterfaces.MongoTransaction)

type Stores

type Stores struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStore

func NewStore() *Stores

func (*Stores) LoadClient

func (c *Stores) LoadClient(id string) (client *Mongo, ok bool)

func (*Stores) LoadClientByTag

func (c *Stores) LoadClientByTag(ta string) (client *Mongo, ok bool)

func (*Stores) StoreClient

func (c *Stores) StoreClient(client *Mongo)