mongo

Documentation

Index

• func Save(db, collection, url string, ctx context.Context, data interface{}) error
• type Driver
  • func NewDriver(url string) (*Driver, error)
  • func (d *Driver) Collection(db, collection string) *mongo.Collection
  • func (d *Driver) Start(ctx context.Context) error
  • func (d *Driver) Stop(ctx context.Context)

Functions

func Save

func Save(db, collection, url string, ctx context.Context, data interface{}) error

Save saves given one entity into db.

Types

type Driver

type Driver struct {
	// contains filtered or unexported fields
}

func NewDriver

func NewDriver(url string) (*Driver, error)

NewDriver returns new mongodb client.

func (*Driver) Collection

func (d *Driver) Collection(db, collection string) *mongo.Collection

Collection returns mongo collection ineterface based on given db and collection.

func (*Driver) Start

func (d *Driver) Start(ctx context.Context) error

Start connects the driver to mongo server.

func (*Driver) Stop

func (d *Driver) Stop(ctx context.Context)

Stop disconnects the driver to mongo server. Not return error (only logging) since easy to use for defer function.