mongodb

Documentation

Index

• Variables
• type A
• type D
• type E
• type M
• type Mongo
  • func New(optionFunc ...OptionFunc) (*Mongo, error)
  • func (mgo *Mongo) Database(name string, opts ...*options.DatabaseOptions) *mongo.Database
  • func (mgo *Mongo) Name() string
  • func (mgo *Mongo) Serve(ctx context.Context) error
  • func (mgo *Mongo) Shutdown(ctx context.Context) error
  • func (mgo *Mongo) StartSession(opts ...*options.SessionOptions) (mongo.Session, error)
  • func (mgo *Mongo) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error
  • func (mgo *Mongo) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, ...) error
• type Monitor
  • func (mon *Monitor) CommandMonitor() *event.CommandMonitor
  • func (mon *Monitor) PoolEventMonitor() *event.PoolMonitor
• type OptionFunc
  • func WithConfigurator(cfg config.SubConfigurator) OptionFunc
  • func WithEnableMonitor(enable bool) OptionFunc
  • func WithName(name string) OptionFunc
• type Options

Variables

var (
	ErrClientDisconnected  = mongo.ErrClientDisconnected
	ErrEmptySlice          = mongo.ErrEmptySlice
	ErrInvalidIndexValue   = mongo.ErrInvalidIndexValue
	ErrMissingResumeToken  = mongo.ErrMissingResumeToken
	ErrMultipleIndexDrop   = mongo.ErrMultipleIndexDrop
	ErrNilCursor           = mongo.ErrNilCursor
	ErrNilDocument         = mongo.ErrNilDocument
	ErrNoDocuments         = mongo.ErrNoDocuments
	ErrNonStringIndexName  = mongo.ErrNonStringIndexName
	ErrUnacknowledgedWrite = mongo.ErrUnacknowledgedWrite
	ErrWrongClient         = mongo.ErrWrongClient
)

Types

type A

type A bson.A

type D

type D bson.D

type E

type E bson.E

type M

type M bson.M

type Mongo

type Mongo struct {
	dummybox.DummyBox
	// contains filtered or unexported fields
}

func New

func New(optionFunc ...OptionFunc) (*Mongo, error)

func (*Mongo) Database

func (mgo *Mongo) Database(name string, opts ...*options.DatabaseOptions) *mongo.Database

func (*Mongo) Name

func (mgo *Mongo) Name() string

func (*Mongo) Serve

func (mgo *Mongo) Serve(ctx context.Context) error

func (*Mongo) Shutdown

func (mgo *Mongo) Shutdown(ctx context.Context) error

func (*Mongo) StartSession

func (mgo *Mongo) StartSession(opts ...*options.SessionOptions) (mongo.Session, error)

func (*Mongo) UseSession

func (mgo *Mongo) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error

func (*Mongo) UseSessionWithOptions

func (mgo *Mongo) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, fn func(mongo.SessionContext) error) error

type Monitor

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

func (*Monitor) CommandMonitor

func (mon *Monitor) CommandMonitor() *event.CommandMonitor

func (*Monitor) PoolEventMonitor

func (mon *Monitor) PoolEventMonitor() *event.PoolMonitor

type OptionFunc

type OptionFunc func(*Options)

func WithConfigurator

func WithConfigurator(cfg config.SubConfigurator) OptionFunc

func WithEnableMonitor

func WithEnableMonitor(enable bool) OptionFunc

func WithName

func WithName(name string) OptionFunc

type Options

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