database

Documentation

Index

• type Builder
  • func NewBuilder(cli *mongo.Client, name string) *Builder
  • func (b *Builder) BSONOptions(opts *options.BSONOptions) *Builder
  • func (b *Builder) Build() *Database
  • func (b *Builder) ReadConcern(rc *readconcern.ReadConcern) *Builder
  • func (b *Builder) ReadPreference(rp *readpref.ReadPref) *Builder
  • func (b *Builder) Registry(r *bsoncodec.Registry) *Builder
  • func (b *Builder) WriteConcern(wc *writeconcern.WriteConcern) *Builder
• type Database
  • func New(primary, defaultReadpref *mongo.Database) *Database
  • func (d *Database) Aggregate(pipe aggregate.Pipeline) *executor.DatabaseAggregateExecutor
  • func (d *Database) Collection(name string) *collection.Builder
  • func (d *Database) Raw() *mongo.Database

Types

type Builder

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

func NewBuilder

func NewBuilder(cli *mongo.Client, name string) *Builder

func (*Builder) BSONOptions

func (b *Builder) BSONOptions(opts *options.BSONOptions) *Builder

BSONOptions configures optional BSON marshaling and unmarshaling behavior.

func (*Builder) Build

func (b *Builder) Build() *Database

func (*Builder) ReadConcern

func (b *Builder) ReadConcern(rc *readconcern.ReadConcern) *Builder

ReadConcern sets the value for the ReadConcern field.

func (*Builder) ReadPreference

func (b *Builder) ReadPreference(rp *readpref.ReadPref) *Builder

ReadPreference sets the value for the ReadPreference field.

func (*Builder) Registry

func (b *Builder) Registry(r *bsoncodec.Registry) *Builder

Registry sets the value for the Registry field.

func (*Builder) WriteConcern

func (b *Builder) WriteConcern(wc *writeconcern.WriteConcern) *Builder

WriteConcern sets the value for the WriteConcern field.

type Database

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

func New

func New(primary, defaultReadpref *mongo.Database) *Database

func (*Database) Aggregate

func (d *Database) Aggregate(pipe aggregate.Pipeline) *executor.DatabaseAggregateExecutor

func (*Database) Collection

func (d *Database) Collection(name string) *collection.Builder

func (*Database) Raw

func (d *Database) Raw() *mongo.Database