mongo

Documentation

Index

• func LoadMongo(tag string, lo loggerInterfaces.Logger, ...) databaseInterfaces.Mongo
• type Mongo
  • func (c *Mongo) Client() (client *mongo.Client, err error)
  • func (c *Mongo) DefaultClient() *mongo.Client
  • func (c *Mongo) GetConfig() databaseInterfaces.MongoProviderConfig
  • func (c *Mongo) OnInitError(e error) (client *mongo.Client, err error)
  • func (c *Mongo) Start() (err error)
• 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 Mongo

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

func (*Mongo) Client

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

func (*Mongo) DefaultClient

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

func (*Mongo) GetConfig

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

func (*Mongo) OnInitError

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

func (*Mongo) Start

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

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)