mongo

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 2, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package mongo provides a MongoDB Driver API for Go.

Basic usage of the driver starts with creating a Client from a connection string. To do so, call the NewClient function: 

client, err := mongo.NewClient("mongodb://foo:bar@localhost:27017")
if err != nil { log.Fatal(err) }

This will create a new client and start monitoring the MongoDB server on localhost. The Database and Collection types can be used to access the database: 

collection := client.Database("baz").Collection("qux")

A Collection can be used to query the database or insert documents: 

res, err := collection.InsertOne(context.Background(), map[string]string{"hello": "world"})
if err != nil { log.Fatal(err) }
id := res.InsertedID

Several methods return a cursor, which can be used like this: 

cur, err := collection.Find(context.Background(), nil)
if err != nil { log.Fatal(err) }
defer cur.Close(context.Background())
for cur.Next(context.Background()) {
   elem := bson.NewDocument()
   err := cur.Decode(elem)
   if err != nil { log.Fatal(err) }
   // do something with elem....
}
if err := cur.Err(); err != nil {
    log.Fatal(err)
}

Methods that only return a single document will return a *DocumentResult, which works like a *sql.Row: 

result := bson.NewDocument()
filter := bson.NewDocument(bson.EC.String("hello", "world"))
err := collection.FindOne(context.Background(), filter).Decode(result)
if err != nil { log.Fatal(err) }
// do something with result...

Additional examples can be found under the examples directory in the driver's repository and on the MongoDB website.

Index

Constants

This section is empty.

Variables

View Source 
var ClientOpt = &ClientOptions{}

ClientOpt is a convenience variable provided for access to ClientOptions methods.

View Source 
var ErrInvalidIndexValue = errors.New("invalid index value")

ErrInvalidIndexValue indicates that the index Keys document has a value that isn't either a number or a string.

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

ErrMissingResumeToken indicates that a change stream notification from the server did not contain a resume token.

View Source 
var ErrMultipleIndexDrop = errors.New("multiple indexes would be dropped")

ErrMultipleIndexDrop indicates that multiple indexes would be dropped from a call to IndexView.DropOne.

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

ErrNoDocuments is returned by Decode when an operation that returns a DocumentResult doesn't return any documents.

View Source 
var ErrNonStringIndexName = errors.New("index name must be a string")

ErrNonStringIndexName indicates that the index name specified in the options is not a string.

View Source 
var ErrUnacknowledgedWrite = errors.New("unacknowledged write")

ErrUnacknowledgedWrite is returned from functions that have an unacknowledged write concern.

Functions

func TransformDocument 

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

TransformDocument handles transforming a document of an allowable type into a *bson.Document. This method is called directly after most methods that have one or more parameters that are documents.

The supported types for document are: 

bson.Marshaler
bson.DocumentMarshaler
bson.Reader
[]byte (must be a valid BSON document)
io.Reader (only 1 BSON document will be read)
A custom struct type

Types

type BulkWriteError 

type BulkWriteError struct {
	WriteErrors       WriteErrors
	WriteConcernError *WriteConcernError
}

BulkWriteError is an error returned from a bulk write operation.

func (BulkWriteError) Error 

func (bwe BulkWriteError) Error() string

type Client 

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

Client performs operations on a given topology.

func Connect 

func Connect(ctx context.Context, uri string, opts *ClientOptions) (*Client, error)

Connect creates a new Client and then initializes it using the Connect method.

func NewClient 

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

NewClient creates a new client to connect to a cluster specified by the uri.

func NewClientFromConnString 

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

NewClientFromConnString creates a new client to connect to a cluster, with configuration specified by the connection string.

func NewClientWithOptions 

func NewClientWithOptions(uri string, opts *ClientOptions) (*Client, error)

NewClientWithOptions creates a new client to connect to to a cluster specified by the connection string and the options manually passed in. If the same option is configured in both the connection string and the manual options, the manual option will be ignored.

func (*Client) Connect 

func (c *Client) Connect(ctx context.Context) error

Connect initializes the Client by starting background monitoring goroutines. This method must be called before a Client can be used.

func (*Client) ConnectionString 

func (c *Client) ConnectionString() string

ConnectionString returns the connection string of the cluster the client is connected to.

func (*Client) Database 

func (c *Client) Database(name string) *Database

Database returns a handle for a given database.

func (*Client) Disconnect 

func (c *Client) Disconnect(ctx context.Context) error

Disconnect closes sockets to the topology referenced by this Client. It will shut down any monitoring goroutines, close the idle connection pool, and will wait until all the in use connections have been returned to the connection pool and closed before returning. If the context expires via cancellation, deadline, or timeout before the in use connections have returned, the in use connections will be closed, resulting in the failure of any in flight read or write operations. If this method returns with no errors, all connections associated with this Client have been closed.

func (*Client) ListDatabaseNames 

func (c *Client) ListDatabaseNames(ctx context.Context, filter interface{}) ([]string, error)

ListDatabaseNames returns a slice containing the names of all of the databases on the server.

func (*Client) ListDatabases 

func (c *Client) ListDatabases(ctx context.Context, filter interface{}) (ListDatabasesResult, error)

ListDatabases returns a ListDatabasesResult.

type ClientOptions 

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

ClientOptions is used as a namespace for mongo.Client option constructors.

func (*ClientOptions) AppName 

func (co *ClientOptions) AppName(s string) *ClientOptions

AppName specifies the client application name. This value is used by MongoDB when it logs connection information and profile information, such as slow queries.

func (*ClientOptions) AuthMechanism 

func (co *ClientOptions) AuthMechanism(s string) *ClientOptions

AuthMechanism indicates the mechanism to use for authentication.

Supported values include "SCRAM-SHA-1", "MONGODB-CR", "PLAIN", "GSSAPI", and "MONGODB-X509".

func (*ClientOptions) AuthMechanismProperties 

func (co *ClientOptions) AuthMechanismProperties(m map[string]string) *ClientOptions

AuthMechanismProperties specifies additional configuration options which may be used by certain authentication mechanisms.

func (*ClientOptions) AuthSource 

func (co *ClientOptions) AuthSource(s string) *ClientOptions

AuthSource specifies the database to authenticate against.

func (*ClientOptions) ConnectTimeout 

func (co *ClientOptions) ConnectTimeout(d time.Duration) *ClientOptions

ConnectTimeout specifies the timeout for an initial connection to a server. If a custom Dialer is used, this method won't be set and the user is responsible for setting the ConnectTimeout for connections on the dialer themselves.

func (*ClientOptions) Dialer 

func (co *ClientOptions) Dialer(d Dialer) *ClientOptions

Dialer specifies a custom dialer used to dial new connections to a server.

func (*ClientOptions) HeartbeatInterval 

func (co *ClientOptions) HeartbeatInterval(d time.Duration) *ClientOptions

HeartbeatInterval specifies the interval to wait between server monitoring checks.

func (*ClientOptions) Hosts 

func (co *ClientOptions) Hosts(s []string) *ClientOptions

Hosts specifies the initial list of addresses from which to discover the rest of the cluster.

func (*ClientOptions) Journal 

func (co *ClientOptions) Journal(b bool) *ClientOptions

Journal specifies the "j" field of the default write concern to set on the Client.

func (*ClientOptions) LocalThreshold 

func (co *ClientOptions) LocalThreshold(d time.Duration) *ClientOptions

LocalThreshold specifies how far to distribute queries, beyond the server with the fastest round-trip time. If a server's roundtrip time is more than LocalThreshold slower than the the fastest, the driver will not send queries to that server.

func (*ClientOptions) MaxConnIdleTime 

func (co *ClientOptions) MaxConnIdleTime(d time.Duration) *ClientOptions

MaxConnIdleTime specifies the maximum number of milliseconds that a connection can remain idle in a connection pool before being removed and closed.

func (*ClientOptions) MaxConnsPerHost 

func (co *ClientOptions) MaxConnsPerHost(u uint16) *ClientOptions

MaxConnsPerHost specifies the max size of a server's connection pool.

func (*ClientOptions) MaxIdleConnsPerHost 

func (co *ClientOptions) MaxIdleConnsPerHost(u uint16) *ClientOptions

MaxIdleConnsPerHost specifies the number of connections in a server's connection pool that can be idle at any given time.

func (*ClientOptions) Password 

func (co *ClientOptions) Password(s string) *ClientOptions

Password specifies the password used for authentication.

func (*ClientOptions) ReadConcernLevel 

func (co *ClientOptions) ReadConcernLevel(s string) *ClientOptions

ReadConcernLevel specifies the read concern level of the default read concern to set on the client.

func (*ClientOptions) ReadPreference 

func (co *ClientOptions) ReadPreference(s string) *ClientOptions

ReadPreference specifies the read preference mode of the default read preference to set on the client.

func (*ClientOptions) ReadPreferenceTagSets 

func (co *ClientOptions) ReadPreferenceTagSets(m []map[string]string) *ClientOptions

ReadPreferenceTagSets specifies the read preference tagsets of the default read preference to set on the client.

func (*ClientOptions) ReplicaSet 

func (co *ClientOptions) ReplicaSet(s string) *ClientOptions

ReplicaSet specifies the name of the replica set of the cluster.

func (*ClientOptions) SSL 

func (co *ClientOptions) SSL(b bool) *ClientOptions

SSL indicates whether SSL should be enabled.

func (*ClientOptions) SSLCaFile 

func (co *ClientOptions) SSLCaFile(s string) *ClientOptions

SSLCaFile specifies the file containing the certificate authority used for SSL connections.

func (*ClientOptions) SSLClientCertificateKeyFile 

func (co *ClientOptions) SSLClientCertificateKeyFile(s string) *ClientOptions

SSLClientCertificateKeyFile specifies the file containing the client certificate and private key used for authentication.

func (*ClientOptions) SSLClientCertificateKeyPassword 

func (co *ClientOptions) SSLClientCertificateKeyPassword(s func() string) *ClientOptions

SSLClientCertificateKeyPassword provides a callback that returns a password used for decrypting the private key of a PEM file (if one is provided).

func (*ClientOptions) SSLInsecure 

func (co *ClientOptions) SSLInsecure(b bool) *ClientOptions

SSLInsecure indicates whether to skip the verification of the server certificate and hostname.

func (*ClientOptions) ServerSelectionTimeout 

func (co *ClientOptions) ServerSelectionTimeout(d time.Duration) *ClientOptions

ServerSelectionTimeout specifies a timeout in milliseconds to block for server selection.

func (*ClientOptions) Single 

func (co *ClientOptions) Single(b bool) *ClientOptions

Single specifies whether the driver should connect directly to the server instead of auto-discovering other servers in the cluster.

func (*ClientOptions) SocketTimeout 

func (co *ClientOptions) SocketTimeout(d time.Duration) *ClientOptions

SocketTimeout specifies the time in milliseconds to attempt to send or receive on a socket before the attempt times out.

func (*ClientOptions) Username 

func (co *ClientOptions) Username(s string) *ClientOptions

Username specifies the username that will be authenticated.

func (*ClientOptions) WNumber 

func (co *ClientOptions) WNumber(i int) *ClientOptions

WNumber sets the "w" field of the default write concern to set on the client.

func (*ClientOptions) WString 

func (co *ClientOptions) WString(s string) *ClientOptions

WString sets the "w" field of the default write concern to set on the client.

func (*ClientOptions) WTimeout 

func (co *ClientOptions) WTimeout(d time.Duration) *ClientOptions

WTimeout sets the "wtimeout" field of the default write concern to set on the client.

type Collection 

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

Collection performs operations on a given collection.

func (*Collection) Aggregate 

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

Aggregate runs an aggregation framework pipeline. A user can supply a custom context to this method.

See https://docs.mongodb.com/manual/aggregation/.

This method uses TransformDocument to turn the pipeline parameter into a *bson.Document. See TransformDocument for the list of valid types for pipeline.

func (*Collection) Count 

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

Count gets the number of documents matching the filter. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) DeleteMany 

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

DeleteMany deletes multiple documents from the collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) DeleteOne 

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

DeleteOne deletes a single document from the collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) Distinct 

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

Distinct finds the distinct values for a specified field across a single collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) Drop 

func (coll *Collection) Drop(ctx context.Context) error

Drop drops this collection from database.

func (*Collection) Find 

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

Find finds the documents matching a model. A user can supply a custom context to this method.

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) FindOne 

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

FindOne returns up to one document that matches the model. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) FindOneAndDelete 

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

FindOneAndDelete find a single document and deletes it, returning the original in result. The document to return may be nil.

A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter parameter into a *bson.Document. See TransformDocument for the list of valid types for filter.

func (*Collection) FindOneAndReplace 

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

FindOneAndReplace finds a single document and replaces it, returning either the original or the replaced document. The document to return may be nil.

A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter and replacement parameter into a *bson.Document. See TransformDocument for the list of valid types for filter and replacement.

func (*Collection) FindOneAndUpdate 

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

FindOneAndUpdate finds a single document and updates it, returning either the original or the updated. The document to return may be nil.

A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter and update parameter into a *bson.Document. See TransformDocument for the list of valid types for filter and update.

func (*Collection) Indexes 

func (coll *Collection) Indexes() IndexView

Indexes returns the index view for this collection.

func (*Collection) InsertMany 

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

InsertMany inserts the provided documents. A user can supply a custom context to this method.

Currently, batching is not implemented for this operation. Because of this, extremely large sets of documents will not fit into a single BSON document to be sent to the server, so the operation will fail.

This method uses TransformDocument to turn the documents parameter into a *bson.Document. See TransformDocument for the list of valid types for documents.

func (*Collection) InsertOne 

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

InsertOne inserts a single document into the collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the document parameter into a *bson.Document. See TransformDocument for the list of valid types for document.

TODO(skriptble): Determine if we should unwrap the value for the InsertOneResult or just return the bson.Element or a bson.Value.

func (*Collection) Name 

func (coll *Collection) Name() string

Name provides access to the name of the collection.

func (*Collection) ReplaceOne 

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

ReplaceOne replaces a single document in the collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter and replacement parameter into a *bson.Document. See TransformDocument for the list of valid types for filter and replacement.

func (*Collection) UpdateMany 

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

UpdateMany updates multiple documents in the collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter and update parameter into a *bson.Document. See TransformDocument for the list of valid types for filter and update.

func (*Collection) UpdateOne 

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

UpdateOne updates a single document in the collection. A user can supply a custom context to this method, or nil to default to context.Background().

This method uses TransformDocument to turn the filter and update parameter into a *bson.Document. See TransformDocument for the list of valid types for filter and update.

func (*Collection) Watch 

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

Watch returns a change stream cursor used to receive notifications of changes to the collection. This method is preferred to running a raw aggregation with a $changeStream stage because it supports resumability in the case of some errors.

type Cursor 

type Cursor interface {

	// Get the ID of the cursor.
	ID() int64

	// Get the next result from the cursor.
	// Returns true if there were no errors and there is a next result.
	Next(context.Context) bool

	Decode(interface{}) error

	DecodeBytes() (bson.Reader, error)

	// Returns the error status of the cursor
	Err() error

	// Close the cursor.
	Close(context.Context) error
}

Cursor instances iterate a stream of documents. Each document is decoded into the result according to the rules of the bson package.

A typical usage of the Cursor interface would be: 

var cur Cursor
ctx := context.Background()
defer cur.Close(ctx)

for cur.Next(ctx) {
	elem := bson.NewDocument()
	if err := cur.Decode(elem); err != nil {
		log.Fatal(err)
	}

	// do something with elem....
}

if err := cur.Err(); err != nil {
	log.Fatal(err)
}

type Database 

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

Database performs operations on a given database.

func (*Database) Client 

func (db *Database) Client() *Client

Client returns the Client the database was created from.

func (*Database) Collection 

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

Collection gets a handle for a given collection in the database.

func (*Database) Drop 

func (db *Database) Drop(ctx context.Context) error

Drop drops this database from mongodb.

func (*Database) Name 

func (db *Database) Name() string

Name returns the name of the database.

func (*Database) RunCommand 

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

RunCommand runs a command on the database. A user can supply a custom context to this method, or nil to default to context.Background().

type DatabaseSpecification 

type DatabaseSpecification struct {
	Name       string
	SizeOnDisk int64
	Empty      bool
}

DatabaseSpecification is the information for a single database returned from a ListDatabases operation.

type DeleteResult 

type DeleteResult struct {
	// The number of documents that were deleted.
	DeletedCount int64 `bson:"n"`
}

DeleteResult is a result of an DeleteOne operation.

type Dialer 

type Dialer interface {
	DialContext(ctx context.Context, network, address string) (net.Conn, error)
}

Dialer is used to make network connections.

type DocumentResult 

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

DocumentResult represents a single document returned from an operation. If the operation returned an error, the Err method of DocumentResult will return that error.

func (*DocumentResult) Decode 

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

Decode will attempt to decode the first document into v. If there was an error from the operation that created this DocumentResult then the error will be returned. If there were no returned documents, ErrNoDocuments is returned.

type IndexModel 

type IndexModel struct {
	Keys    *bson.Document
	Options *bson.Document
}

IndexModel contains information about an index.

type IndexView 

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

IndexView is used to create, drop, and list indexes on a given collection.

func (IndexView) CreateMany 

func (iv IndexView) CreateMany(ctx context.Context, models ...IndexModel) ([]string, error)

CreateMany creates multiple indexes in the collection specified by the models. The names of the creates indexes are returned.

func (IndexView) CreateOne 

func (iv IndexView) CreateOne(ctx context.Context, model IndexModel) (string, error)

CreateOne creates a single index in the collection specified by the model.

func (IndexView) DropAll 

func (iv IndexView) DropAll(ctx context.Context) (bson.Reader, error)

DropAll drops all indexes in the collection.

func (IndexView) DropOne 

func (iv IndexView) DropOne(ctx context.Context, name string) (bson.Reader, error)

DropOne drops the index with the given name from the collection.

func (IndexView) List 

func (iv IndexView) List(ctx context.Context) (Cursor, error)

List returns a cursor iterating over all the indexes in the collection.

type InsertManyResult 

type InsertManyResult struct {
	// Maps the indexes of inserted documents to their _id fields.
	InsertedIDs []interface{}
}

InsertManyResult is a result of an InsertMany operation.

type InsertOneResult 

type InsertOneResult struct {
	// The identifier that was inserted.
	InsertedID interface{}
}

InsertOneResult is a result of an InsertOne operation.

InsertedID will be a Go type that corresponds to a BSON type.

type ListDatabasesResult 

type ListDatabasesResult struct {
	Databases []DatabaseSpecification
	TotalSize int64
}

ListDatabasesResult is a result of a ListDatabases operation. Each specification is a description of the datbases on the server.

type Options 

type Options struct{}

Options is used as a namespace for MongoDB operation option constructors. 

var Opt Options

Opt is a convenience variable provided for access to Options methods.

func (Options) AllowDiskUse 

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

AllowDiskUse enables writing to temporary files.

func (Options) AllowPartialResults 

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

AllowPartialResults gets partial results from a mongos if some shards are down (instead of throwing an error).

func (Options) ArrayFilters 

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

ArrayFilters specifies to which array elements an update should apply.

This function uses TransformDocument to turn the document parameter into a *bson.Document. See TransformDocument for the list of valid types for document.

func (Options) BatchSize 

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

BatchSize specifies the number of documents to return per batch.

func (Options) BypassDocumentValidation 

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

BypassDocumentValidation is used to opt out of document-level validation for a given write.

func (Options) Collation 

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

Collation allows users to specify language-specific rules for string comparison, such as rules for lettercase and accent marks.

See https://docs.mongodb.com/manual/reference/collation/.

func (Options) Comment 

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

Comment specifies a comment to attach to the query to help attach and trace profile data.

See https://docs.mongodb.com/manual/reference/command/profile.

func (Options) CursorType 

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

CursorType indicates the type of cursor to use.

func (Options) FullDocument 

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

FullDocument indicates which changes should be returned in a change stream notification.

If fullDocument is "updateLookup", then the change notification for partial updates will include both a delta describing the changes to the document as well as a copy of the entire document that was changed from some time after the change occurred.

func (Options) Hint 

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

Hint specifies the index to use.

The hint parameter must be either a string or a document. If it is a document, this func (Options)tion uses TransformDocument to turn the document into a *bson.Document. See TransformDocument for the list of valid types.

func (Options) Limit 

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

Limit specifies the maximum number of documents to return.

func (Options) Max 

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

Max specifies the exclusive upper bound for a specific index.

This function uses TransformDocument to turn the max parameter into a *bson.Document. See TransformDocument for the list of valid types for max.

func (Options) MaxAwaitTime 

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

MaxAwaitTime specifies the maximum amount of time for the server to wait on new documents to satisfy a tailable-await cursor query.

func (Options) MaxScan 

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

MaxScan specifies the maximum number of documents or index keys to scan when executing the query.

func (Options) MaxTime 

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

MaxTime specifies the maximum amount of time to allow the query to run.

func (Options) Min 

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

Min specifies the inclusive lower bound for a specific index.

This function uses TransformDocument to turn the min parameter into a *bson.Document. See TransformDocument for the list of valid types for min.

func (Options) NoCursorTimeout 

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

NoCursorTimeout specifies whether to prevent the server from timing out idle cursors after an inactivity period.

func (Options) OplogReplay 

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

OplogReplay is for internal replication use only.

func (Options) Ordered 

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

Ordered specifies whether the remaining writes should be aborted if one of the earlier ones fails.

func (Options) Projection 

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

Projection limits the fields to return for all matching documents.

This function uses TransformDocument to turn the projection parameter into a *bson.Document. See TransformDocument for the list of valid types for projection.

func (Options) ReadConcern 

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

ReadConcern for replica sets and replica set shards determines which data to return from a query.

func (Options) ResumeAfter 

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

ResumeAfter specifies the logical starting point for a new change stream.

func (Options) ReturnDocument 

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

ReturnDocument specifies whether a findAndUpdate should return the document as it was before the update or as it is after.

func (Options) ReturnKey 

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

ReturnKey specifies whether to only return the index keys in the resulting documents.

func (Options) ShowRecordID 

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

ShowRecordID determines whether to return the record identifier for each document.

func (Options) Skip 

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

Skip specifies the number of documents to skip before returning.

func (Options) Snapshot 

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

Snapshot specifies whether to prevent the cursor from returning a document more than once because of an intervening write operation.

func (Options) Sort 

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

Sort specifies order in which to return matching documents.

This function uses TransformDocument to turn the sort parameter into a *bson.Document. See TransformDocument for the list of valid types for sort.

func (Options) Upsert 

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

Upsert specifies that a new document should be inserted if no document matches the update filter.

func (Options) WriteConcern 

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

WriteConcern describes the level of acknowledgement requested from MongoDB for write operations to a standalone mongod or to replica sets or to sharded clusters.

type UpdateResult 

type UpdateResult struct {
	// The number of documents that matched the filter.
	MatchedCount int64
	// The number of documents that were modified.
	ModifiedCount int64
	// The identifier of the inserted document if an upsert took place.
	UpsertedID interface{}
}

UpdateResult is a result of an update operation.

UpsertedID will be a Go type that corresponds to a BSON type.

func (*UpdateResult) UnmarshalBSON 

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

UnmarshalBSON implements the bson.Unmarshaler interface.

type WriteConcernError 

type WriteConcernError struct {
	Code    int
	Message string
	Details bson.Reader
}

WriteConcernError is a write concern failure that occured as a result of a write operation.

func (WriteConcernError) Error 

func (wce WriteConcernError) Error() string

type WriteError 

type WriteError struct {
	Index   int
	Code    int
	Message string
}

WriteError is a non-write concern failure that occured as a result of a write operation.

func (WriteError) Error 

func (we WriteError) Error() string

type WriteErrors 

type WriteErrors []WriteError

WriteErrors is a group of non-write concern failures that occured as a result of a write operation.

func (WriteErrors) Error 

func (we WriteErrors) Error() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.