Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mongo

package

Go to main page

Versions in this module

v0

v0.0.2

Mar 6, 2018

Changes in this version

+ var ErrMissingResumeToken = errors.New("cannot provide resume functionality when the resume token is missing")

type Collection

+ func (coll *Collection) Watch(ctx context.Context, pipeline interface{}, ...) (Cursor, error)

type Cursor

+ Close func(context.Context) error

+ Decode func(interface{}) error

+ DecodeBytes func() (bson.Reader, error)

+ Err func() error

+ ID func() int64

+ Next func(context.Context) bool

+ type Options struct

+ var Opt Options

+ func (Options) AllowDiskUse(b bool) options.OptAllowDiskUse

+ func (Options) AllowPartialResults(b bool) options.OptAllowPartialResults

+ func (Options) ArrayFilters(filters ...interface{}) (options.OptArrayFilters, error)

+ func (Options) BatchSize(i int32) options.OptBatchSize

+ func (Options) BypassDocumentValidation(b bool) options.OptBypassDocumentValidation

+ func (Options) Collation(collation *options.Collation) options.OptCollation

+ func (Options) Comment(s string) options.OptComment

+ func (Options) CursorType(cursorType options.CursorType) options.OptCursorType

+ func (Options) FullDocument(fullDocument string) options.OptFullDocument

+ func (Options) Hint(hint interface{}) (options.OptHint, error)

+ func (Options) Limit(i int64) options.OptLimit

+ func (Options) Max(max interface{}) (options.OptMax, error)

+ func (Options) MaxAwaitTime(duration time.Duration) options.OptMaxAwaitTime

+ func (Options) MaxScan(i int64) options.OptMaxScan

+ func (Options) MaxTime(duration time.Duration) options.OptMaxTime

+ func (Options) Min(min interface{}) (options.OptMin, error)

+ func (Options) NoCursorTimeout(b bool) options.OptNoCursorTimeout

+ func (Options) OplogReplay(b bool) options.OptOplogReplay

+ func (Options) Ordered(b bool) options.OptOrdered

+ func (Options) Projection(projection interface{}) (options.OptProjection, error)

+ func (Options) ReadConcern(readConcern *readconcern.ReadConcern) (options.OptReadConcern, error)

+ func (Options) ResumeAfter(token *bson.Document) options.OptResumeAfter

+ func (Options) ReturnDocument(returnDocument options.ReturnDocument) options.OptReturnDocument

+ func (Options) ReturnKey(b bool) options.OptReturnKey

+ func (Options) ShowRecordID(b bool) options.OptShowRecordID

+ func (Options) Skip(i int64) options.OptSkip

+ func (Options) Snapshot(b bool) options.OptSnapshot

+ func (Options) Sort(sort interface{}) (options.OptSort, error)

+ func (Options) Upsert(b bool) options.OptUpsert

+ func (Options) WriteConcern(writeConcern *writeconcern.WriteConcern) (options.OptWriteConcern, error)

v0.0.1

Feb 13, 2018

Changes in this version

+ var ErrNoDocuments = errors.New("mongo: no documents in result")

+ func AllowDiskUse(b bool) options.OptAllowDiskUse

+ func AllowPartialResults(b bool) options.OptAllowPartialResults

+ func ArrayFilters(filters ...interface{}) (options.OptArrayFilters, error)

+ func BatchSize(i int32) options.OptBatchSize

+ func BypassDocumentValidation(b bool) options.OptBypassDocumentValidation

+ func Collation(collation *options.CollationOptions) options.OptCollation

+ func Comment(s string) options.OptComment

+ func CursorType(cursorType options.CursorType) options.OptCursorType

+ func Hint(hint interface{}) (options.OptHint, error)

+ func Limit(i int64) options.OptLimit

+ func Max(max interface{}) (options.OptMax, error)

+ func MaxAwaitTime(duration time.Duration) options.OptMaxAwaitTime

+ func MaxScan(i int64) options.OptMaxScan

+ func MaxTime(duration time.Duration) options.OptMaxTime

+ func Min(min interface{}) (options.OptMin, error)

+ func NoCursorTimeout(b bool) options.OptNoCursorTimeout

+ func OplogReplay(b bool) options.OptOplogReplay

+ func Ordered(b bool) options.OptOrdered

+ func Projection(projection interface{}) (options.OptProjection, error)

+ func ReturnDocument(returnDocument options.ReturnDocument) options.OptReturnDocument

+ func ReturnKey(b bool) options.OptReturnKey

+ func ShowRecordID(b bool) options.OptShowRecordID

+ func Skip(i int64) options.OptSkip

+ func Snapshot(b bool) options.OptSnapshot

+ func Sort(sort interface{}) (options.OptSort, error)

+ func TransformDocument(document interface{}) (*bson.Document, error)

+ func Upsert(b bool) options.OptUpsert

+ type Client struct

+ func NewClient(uri string) (*Client, error)

+ func NewClientFromConnString(cs connstring.ConnString) (*Client, error)

+ func (client *Client) ConnectionString() string

+ func (client *Client) Database(name string) *Database

+ type Collection struct

+ func (coll *Collection) Aggregate(ctx context.Context, pipeline interface{}, ...) (Cursor, error)

+ func (coll *Collection) Count(ctx context.Context, filter interface{}, options ...options.CountOptioner) (int64, error)

+ func (coll *Collection) DeleteMany(ctx context.Context, filter interface{}, options ...options.DeleteOptioner) (*DeleteResult, error)

+ func (coll *Collection) DeleteOne(ctx context.Context, filter interface{}, options ...options.DeleteOptioner) (*DeleteResult, error)

+ func (coll *Collection) Distinct(ctx context.Context, fieldName string, filter interface{}, ...) ([]interface{}, error)

+ func (coll *Collection) Find(ctx context.Context, filter interface{}, options ...options.FindOptioner) (Cursor, error)

+ func (coll *Collection) FindOne(ctx context.Context, filter interface{}, options ...options.FindOptioner) *DocumentResult

+ func (coll *Collection) FindOneAndDelete(ctx context.Context, filter interface{}, ...) *DocumentResult

+ func (coll *Collection) FindOneAndReplace(ctx context.Context, filter interface{}, replacement interface{}, ...) *DocumentResult

+ func (coll *Collection) FindOneAndUpdate(ctx context.Context, filter interface{}, update interface{}, ...) *DocumentResult

+ func (coll *Collection) InsertMany(ctx context.Context, documents []interface{}, ...) (*InsertManyResult, error)

+ func (coll *Collection) InsertOne(ctx context.Context, document interface{}, options ...options.InsertOptioner) (*InsertOneResult, error)

+ func (coll *Collection) ReplaceOne(ctx context.Context, filter interface{}, replacement interface{}, ...) (*UpdateResult, error)

+ func (coll *Collection) UpdateMany(ctx context.Context, filter interface{}, update interface{}, ...) (*UpdateResult, error)

+ func (coll *Collection) UpdateOne(ctx context.Context, filter interface{}, update interface{}, ...) (*UpdateResult, error)

+ type Cursor ops.Cursor

+ type Database struct

+ func (db *Database) Client() *Client

+ func (db *Database) Collection(name string) *Collection

+ func (db *Database) Name() string

+ func (db *Database) RunCommand(ctx context.Context, command interface{}) (bson.Reader, error)

+ type DeleteResult struct

+ DeletedCount int64

+ type DocumentResult struct

+ func (dr *DocumentResult) Decode(v interface{}) error

+ type InsertManyResult struct

+ InsertedIDs []interface{}

+ type InsertOneResult struct

+ InsertedID interface{}

+ type UpdateResult struct

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedID interface{}

+ func (result *UpdateResult) UnmarshalBSON(b []byte) error