driver

package

Go to main page

Versions in this module

v1

v1.0.2

Aug 29, 2019

Changes in this version

+ var ErrCursorNotFound = errors.New("cursor not found")

+ var ErrDocumentTooLarge = errors.New("an inserted document is too large")

+ var ErrMultiDocCommandResponse = errors.New("command returned multiple documents")

+ var ErrNoDocCommandResponse = errors.New("command returned no documents")

+ var ErrNonPrimaryReadPref = errors.New("read preference in a transaction must be primary")

+ var ErrReplyDocumentMismatch = errors.New("number of documents returned does not match numberReturned field")

+ var ErrUnacknowledgedWrite = errors.New("unacknowledged write")

+ var ErrUnsupportedStorageEngine = errors.New(...)

+ var NetworkError = "NetworkError"

+ var TransientTransactionError = "TransientTransactionError"

+ var UnknownTransactionCommitResult = "UnknownTransactionCommitResult"

type BatchCursor

+ func (bc *BatchCursor) KillCursor(ctx context.Context) error

+ func (bc *BatchCursor) PostBatchResumeToken() bsoncore.Document

+ type Batches struct

+ Current []bsoncore.Document

+ Documents []bsoncore.Document

+ Identifier string

+ Ordered *bool

+ func (b *Batches) AdvanceBatch(maxCount, targetBatchSize int) error

+ func (b *Batches) ClearBatch()

+ func (b *Batches) Valid() bool

+ type CollectionInfoFn func(ctx context.Context, db string, filter bsoncore.Document) (bsoncore.Document, error)

+ type Compressor interface

+ CompressWireMessage func(src, dst []byte) ([]byte, error)

+ type Connection interface

+ Address func() address.Address

+ Close func() error

+ Description func() description.Server

+ ID func() string

+ ReadWireMessage func(ctx context.Context, dst []byte) ([]byte, error)

+ WriteWireMessage func(context.Context, []byte) error

+ type Connector interface

+ Connect func() error

+ type Crypt struct

+ BypassAutoEncryption bool

+ func NewCrypt(opts *CryptOptions) (*Crypt, error)

+ func (c *Crypt) Close()

+ func (c *Crypt) CreateDataKey(ctx context.Context, kmsProvider string, opts *options.DataKeyOptions) (bsoncore.Document, error)

+ func (c *Crypt) Decrypt(ctx context.Context, cmdResponse bsoncore.Document) (bsoncore.Document, error)

+ func (c *Crypt) DecryptExplicit(ctx context.Context, subtype byte, data []byte) (bsoncore.Value, error)

+ func (c *Crypt) Encrypt(ctx context.Context, db string, cmd bsoncore.Document) (bsoncore.Document, error)

+ func (c *Crypt) EncryptExplicit(ctx context.Context, val bsoncore.Value, ...) (byte, []byte, error)

+ type CryptOptions struct

+ BypassAutoEncryption bool

+ CollInfoFn CollectionInfoFn

+ KeyFn KeyRetrieverFn

+ KmsProviders map[string]map[string]interface{}

+ MarkFn MarkCommandFn

+ SchemaMap map[string]bsoncore.Document

+ type CursorOptions struct

+ BatchSize int32

+ CommandMonitor *event.CommandMonitor

+ Crypt *Crypt

+ Limit int32

+ MaxTimeMS int64

+ type CursorResponse struct

+ Collection string

+ Database string

+ Desc description.Server

+ FirstBatch *bsoncore.DocumentSequence

+ ID int64

+ Server Server

+ func NewCursorResponse(response bsoncore.Document, server Server, desc description.Server) (CursorResponse, error)

+ type Deployment interface

+ Kind func() description.TopologyKind

+ SelectServer func(context.Context, description.ServerSelector) (Server, error)

+ SupportsRetryWrites func() bool

+ type Disconnector interface

+ Disconnect func(context.Context) error

+ type Error struct

+ Code int32

+ Labels []string

+ Message string

+ Name string

+ func (e Error) Error() string

+ func (e Error) HasErrorLabel(label string) bool

+ func (e Error) NamespaceNotFound() bool

+ func (e Error) NetworkError() bool

+ func (e Error) NodeIsRecovering() bool

+ func (e Error) NodeIsShuttingDown() bool

+ func (e Error) NotMaster() bool

+ func (e Error) Retryable() bool

+ func (e Error) UnsupportedStorageEngine() bool

+ type ErrorProcessor interface

+ ProcessError func(error)

+ type Expirable interface

+ Alive func() bool

+ Expire func() error

+ type Handshaker interface

+ Handshake func(context.Context, address.Address, Connection) (description.Server, error)

+ type HandshakerFunc func(context.Context, address.Address, Connection) (description.Server, error)

+ func (hf HandshakerFunc) Handshake(ctx context.Context, addr address.Address, conn Connection) (description.Server, error)

+ type InvalidOperationError struct

+ MissingField string

+ func (err InvalidOperationError) Error() string

+ type KeyRetrieverFn func(ctx context.Context, filter bsoncore.Document) ([]bsoncore.Document, error)

+ type LegacyOperationKind uint

+ const LegacyFind

+ const LegacyGetMore

+ const LegacyKillCursors

+ const LegacyListCollections

+ const LegacyListIndexes

+ const LegacyNone

+ type LocalAddresser interface

+ LocalAddress func() address.Address

+ type MarkCommandFn func(ctx context.Context, db string, cmd bsoncore.Document) (bsoncore.Document, error)

+ type Operation struct

+ Batches *Batches

+ Client *session.Client

+ Clock *session.ClusterClock

+ CommandFn func(dst []byte, desc description.SelectedServer) ([]byte, error)

+ CommandMonitor *event.CommandMonitor

+ Crypt *Crypt

+ Database string

+ Deployment Deployment

+ Legacy LegacyOperationKind

+ MinimumReadConcernWireVersion int32

+ MinimumWriteConcernWireVersion int32

+ ProcessResponseFn func(response bsoncore.Document, srvr Server, desc description.Server) error

+ ReadConcern *readconcern.ReadConcern

+ ReadPreference *readpref.ReadPref

+ RetryMode *RetryMode

+ Selector description.ServerSelector

+ Type Type

+ WriteConcern *writeconcern.WriteConcern

+ func (op Operation) Execute(ctx context.Context, scratch []byte) error

+ func (op Operation) Validate() error

+ type QueryFailureError struct

+ Message string

+ Response bsoncore.Document

+ func (e QueryFailureError) Error() string

+ type ResponseError struct

+ Message string

+ Wrapped error

+ func NewCommandResponseError(msg string, err error) ResponseError

+ func (e ResponseError) Error() string

+ type RetryMode uint

+ const RetryContext

+ const RetryNone

+ const RetryOnce

+ const RetryOncePerCommand

+ func (rm RetryMode) Enabled() bool

+ type Server interface

+ Connection func(context.Context) (Connection, error)

+ type SingleConnectionDeployment struct

+ C Connection

+ func (ssd SingleConnectionDeployment) Connection(context.Context) (Connection, error)

+ func (ssd SingleConnectionDeployment) Kind() description.TopologyKind

+ func (ssd SingleConnectionDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)

+ func (ssd SingleConnectionDeployment) SupportsRetryWrites() bool

+ type SingleServerDeployment struct

+ func (SingleServerDeployment) Kind() description.TopologyKind

+ func (SingleServerDeployment) SupportsRetryWrites() bool

+ func (ssd SingleServerDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)

+ type Subscriber interface

+ Subscribe func() (*Subscription, error)

+ Unsubscribe func(*Subscription) error

+ type Subscription struct

+ ID uint64

+ Updates <-chan description.Topology

+ type Type uint

+ type WriteCommandError struct

+ WriteConcernError *WriteConcernError

+ WriteErrors WriteErrors

+ func (wce WriteCommandError) Error() string

+ func (wce WriteCommandError) Retryable() bool

+ func (wce WriteCommandError) UnsupportedStorageEngine() bool

+ type WriteConcernError struct

+ Code int64

+ Details bsoncore.Document

+ Message string

+ Name string

+ func (wce WriteConcernError) Error() string

+ func (wce WriteConcernError) NodeIsRecovering() bool

+ func (wce WriteConcernError) NodeIsShuttingDown() bool

+ func (wce WriteConcernError) NotMaster() bool

+ func (wce WriteConcernError) Retryable() bool

+ type WriteError struct

+ Code int64

+ Index int64

+ Message string

+ func (we WriteError) Error() string

+ type WriteErrors []WriteError

+ func (we WriteErrors) Error() string

v1.0.1

Apr 18, 2019

v1.0.0

Mar 13, 2019

Changes in this version

type BatchCursor

+ func (bc *BatchCursor) Server() *topology.Server

type ListCollectionsBatchCursor

+ func (lcbc *ListCollectionsBatchCursor) Server() *topology.Server

v1.0.0-rc2

Mar 7, 2019

v1.0.0-rc1

Feb 22, 2019

v0

v0.3.0

Feb 1, 2019

Changes in this version

+ type BatchCursor struct

+ func NewBatchCursor(result bsoncore.Document, clientSession *session.Client, ...) (*BatchCursor, error)

+ func NewEmptyBatchCursor() *BatchCursor

+ func NewLegacyBatchCursor(ns command.Namespace, cursorID int64, batch []bson.Raw, limit int32, ...) (*BatchCursor, error)

+ func (bc *BatchCursor) Batch(dst []byte) []byte

+ func (bc *BatchCursor) Close(ctx context.Context) error

+ func (bc *BatchCursor) Err() error

+ func (bc *BatchCursor) ID() int64

+ func (bc *BatchCursor) Next(ctx context.Context) bool

+ func (bc *BatchCursor) RequiredBytes() int

+ type ListCollectionsBatchCursor struct

+ func NewLegacyListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error)

+ func NewListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error)

+ func (lcbc *ListCollectionsBatchCursor) Batch(dst []byte) []byte

+ func (lcbc *ListCollectionsBatchCursor) Close(ctx context.Context) error

+ func (lcbc *ListCollectionsBatchCursor) Err() error

+ func (lcbc *ListCollectionsBatchCursor) ID() int64

+ func (lcbc *ListCollectionsBatchCursor) Next(ctx context.Context) bool

+ func (lcbc *ListCollectionsBatchCursor) RequiredBytes() int

v0.2.0

Jan 8, 2019

Changes in this version

+ var ErrFilterType = errors.New("filter must be a string")

v0.1.0

Dec 6, 2018

Changes in this version

+ var ErrArrayFilters = errors.New("array filters cannot be set for server versions < 3.6")

+ var ErrCollation = errors.New("collation cannot be set for server versions < 3.4")

+ func AbortTransaction(ctx context.Context, cmd command.AbortTransaction, topo *topology.Topology, ...) (result.TransactionResult, error)

+ func Aggregate(ctx context.Context, cmd command.Aggregate, topo *topology.Topology, ...) (command.Cursor, error)

+ func BulkWrite(ctx context.Context, ns command.Namespace, models []WriteModel, ...) (result.BulkWrite, error)

+ func CommitTransaction(ctx context.Context, cmd command.CommitTransaction, topo *topology.Topology, ...) (result.TransactionResult, error)

+ func Count(ctx context.Context, cmd command.Count, topo *topology.Topology, ...) (int64, error)

+ func CountDocuments(ctx context.Context, cmd command.CountDocuments, topo *topology.Topology, ...) (int64, error)

+ func CreateIndexes(ctx context.Context, cmd command.CreateIndexes, topo *topology.Topology, ...) (result.CreateIndexes, error)

+ func Delete(ctx context.Context, cmd command.Delete, topo *topology.Topology, ...) (result.Delete, error)

+ func Distinct(ctx context.Context, cmd command.Distinct, topo *topology.Topology, ...) (result.Distinct, error)

+ func DropCollection(ctx context.Context, cmd command.DropCollection, topo *topology.Topology, ...) (bson.Raw, error)

+ func DropDatabase(ctx context.Context, cmd command.DropDatabase, topo *topology.Topology, ...) (bson.Raw, error)

+ func DropIndexes(ctx context.Context, cmd command.DropIndexes, topo *topology.Topology, ...) (bson.Raw, error)

+ func EndSessions(ctx context.Context, cmd command.EndSessions, topo *topology.Topology, ...) ([]result.EndSessions, []error)

+ func Find(ctx context.Context, cmd command.Find, topo *topology.Topology, ...) (command.Cursor, error)

+ func FindOneAndDelete(ctx context.Context, cmd command.FindOneAndDelete, topo *topology.Topology, ...) (result.FindAndModify, error)

+ func FindOneAndReplace(ctx context.Context, cmd command.FindOneAndReplace, topo *topology.Topology, ...) (result.FindAndModify, error)

+ func FindOneAndUpdate(ctx context.Context, cmd command.FindOneAndUpdate, topo *topology.Topology, ...) (result.FindAndModify, error)

+ func Insert(ctx context.Context, cmd command.Insert, topo *topology.Topology, ...) (result.Insert, error)

+ func KillCursors(ctx context.Context, cmd command.KillCursors, topo *topology.Topology, ...) (result.KillCursors, error)

+ func ListCollections(ctx context.Context, cmd command.ListCollections, topo *topology.Topology, ...) (command.Cursor, error)

+ func ListDatabases(ctx context.Context, cmd command.ListDatabases, topo *topology.Topology, ...) (result.ListDatabases, error)

+ func ListIndexes(ctx context.Context, cmd command.ListIndexes, topo *topology.Topology, ...) (command.Cursor, error)

+ func Read(ctx context.Context, cmd command.Read, topo *topology.Topology, ...) (bson.Raw, error)

+ func ReadCursor(ctx context.Context, cmd command.Read, topo *topology.Topology, ...) (command.Cursor, error)

+ func Update(ctx context.Context, cmd command.Update, topo *topology.Topology, ...) (result.Update, error)

+ func Write(ctx context.Context, cmd command.Write, topo *topology.Topology, ...) (bson.Raw, error)

+ type BulkWriteError struct

+ Model WriteModel

+ type BulkWriteException struct

+ WriteConcernError *result.WriteConcernError

+ WriteErrors []BulkWriteError

+ func (BulkWriteException) Error() string

+ type DeleteManyModel struct

+ Collation *options.Collation

+ Filter interface{}

+ type DeleteOneModel struct

+ Collation *options.Collation

+ Filter interface{}

+ type InsertOneModel struct

+ Document interface{}

+ type ReplaceOneModel struct

+ Filter interface{}

+ Replacement interface{}

+ type UpdateManyModel struct

+ ArrayFilters options.ArrayFilters

+ ArrayFiltersSet bool

+ Filter interface{}

+ Update interface{}

+ type UpdateModel struct

+ Collation *options.Collation

+ Upsert bool

+ UpsertSet bool

+ type UpdateOneModel struct

+ ArrayFilters options.ArrayFilters

+ ArrayFiltersSet bool

+ Filter interface{}

+ Update interface{}

+ type WriteModel interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL