driver

package

Go to main page

Versions in this module

v1

v1.3.5

Mar 27, 2020

v1.3.4

Mar 27, 2020

v1.3.3

Mar 26, 2020

v1.3.2

Mar 26, 2020

Changes in this version

+ var RetryableWriteError = "RetryableWriteError"

+ func CompressPayload(in []byte, opts CompressionOpts) ([]byte, error)

type Error

+ func (e Error) RetryableRead() bool

+ func (e Error) RetryableWrite(wireVersion *description.VersionRange) bool

type WriteCommandError

+ Labels []string

type WriteConcernError

+ Labels []string

v1.2.1

Jan 8, 2020

Changes in this version

type Error

+ Wrapped error

v1.2.0

Dec 10, 2019

Changes in this version

+ func CompressPlayoad(in []byte, opts CompressionOpts) ([]byte, error)

+ func DecompressPayload(in []byte, opts CompressionOpts) ([]byte, error)

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

+ type CompressionOpts struct

+ Compressor wiremessage.CompressorID

+ UncompressedSize int32

+ ZlibLevel int

+ ZstdLevel int

+ 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

+ Crypt *Crypt

+ type Disconnector interface

+ Disconnect func(context.Context) error

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

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

type Operation

+ Crypt *Crypt

+ type Subscriber interface

+ Subscribe func() (*Subscription, error)

+ Unsubscribe func(*Subscription) error

+ type Subscription struct

+ ID uint64

+ Updates <-chan description.Topology

v1.1.4

Dec 17, 2019

v1.1.3

Nov 5, 2019

v1.1.2

Oct 7, 2019

Changes in this version

type Handshaker

+ FinishHandshake func(context.Context, Connection) error

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

v1.1.1

Sep 5, 2019

v1.1.0

Aug 13, 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 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 CursorOptions struct

+ BatchSize int32

+ CommandMonitor *event.CommandMonitor

+ 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 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 LegacyOperationKind uint

+ const LegacyFind

+ const LegacyGetMore

+ const LegacyKillCursors

+ const LegacyListCollections

+ const LegacyListIndexes

+ const LegacyNone

+ type LocalAddresser interface

+ LocalAddress func() address.Address

+ type Operation struct

+ Batches *Batches

+ Client *session.Client

+ Clock *session.ClusterClock

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

+ CommandMonitor *event.CommandMonitor

+ 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 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.4

Jul 9, 2019

v1.0.3

Jun 6, 2019

v1.0.2

May 16, 2019

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