command

package

Go to main page

Versions in this module

v1

v1.0.1

Apr 18, 2019

v1.0.0

Mar 13, 2019

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

+ var ErrEmptyCursor = errors.New("empty cursor")

v0.2.0

Jan 8, 2019

Changes in this version

+ var ReplyDocumentMismatch = "malformed OP_REPLY: NumberReturned does not match number of documents returned"

type CursorBuilder

+ BuildLegacyCursor func(Namespace, int64, []bson.Raw, int32, int32) (Cursor, error)

v0.1.0

Dec 6, 2018

Changes in this version

+ const BatchSize

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

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

+ var ErrNoCommandResponse = errors.New("no command response document")

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

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

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

+ var ErrUnknownCommandFailure = errors.New("unknown command failure")

+ var NetworkError = "NetworkError"

+ var TransientTransactionError = "TransientTransactionError"

+ var UnknownTransactionCommitResult = "UnknownTransactionCommitResult"

+ func ClientDoc(app string) bsonx.Doc

+ func DecodeError(wm wiremessage.WireMessage) error

+ func IsNotFound(err error) bool

+ func IsWriteConcernErrorRetryable(wce *result.WriteConcernError) bool

+ type AbortTransaction struct

+ Session *session.Client

+ func (at *AbortTransaction) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *AbortTransaction

+ func (at *AbortTransaction) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (at *AbortTransaction) Err() error

+ func (at *AbortTransaction) Result() (result.TransactionResult, error)

+ func (at *AbortTransaction) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.TransactionResult, error)

+ type Aggregate struct

+ Clock *session.ClusterClock

+ CursorOpts []bsonx.Elem

+ NS Namespace

+ Opts []bsonx.Elem

+ Pipeline bsonx.Arr

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (a *Aggregate) Decode(desc description.SelectedServer, cb CursorBuilder, wm wiremessage.WireMessage) *Aggregate

+ func (a *Aggregate) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (a *Aggregate) Err() error

+ func (a *Aggregate) HasDollarOut() bool

+ func (a *Aggregate) Result() (Cursor, error)

+ func (a *Aggregate) RoundTrip(ctx context.Context, desc description.SelectedServer, cb CursorBuilder, ...) (Cursor, error)

+ type BuildInfo struct

+ func (bi *BuildInfo) Decode(wm wiremessage.WireMessage) *BuildInfo

+ func (bi *BuildInfo) Encode() (wiremessage.WireMessage, error)

+ func (bi *BuildInfo) Err() error

+ func (bi *BuildInfo) Result() (result.BuildInfo, error)

+ func (bi *BuildInfo) RoundTrip(ctx context.Context, rw wiremessage.ReadWriter) (result.BuildInfo, error)

+ type CommitTransaction struct

+ Session *session.Client

+ func (ct *CommitTransaction) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *CommitTransaction

+ func (ct *CommitTransaction) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (ct *CommitTransaction) Err() error

+ func (ct *CommitTransaction) Result() (result.TransactionResult, error)

+ func (ct *CommitTransaction) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.TransactionResult, error)

+ type Count struct

+ Clock *session.ClusterClock

+ NS Namespace

+ Opts []bsonx.Elem

+ Query bsonx.Doc

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ func (c *Count) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Count

+ func (c *Count) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (c *Count) Err() error

+ func (c *Count) Result() (int64, error)

+ func (c *Count) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (int64, error)

+ type CountDocuments struct

+ Clock *session.ClusterClock

+ NS Namespace

+ Opts []bsonx.Elem

+ Pipeline bsonx.Arr

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ func (c *CountDocuments) Decode(ctx context.Context, desc description.SelectedServer, cb CursorBuilder, ...) *CountDocuments

+ func (c *CountDocuments) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (c *CountDocuments) Err() error

+ func (c *CountDocuments) Result() (int64, error)

+ func (c *CountDocuments) RoundTrip(ctx context.Context, desc description.SelectedServer, cb CursorBuilder, ...) (int64, error)

+ type CreateIndexes struct

+ Clock *session.ClusterClock

+ Indexes bsonx.Arr

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (ci *CreateIndexes) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *CreateIndexes

+ func (ci *CreateIndexes) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (ci *CreateIndexes) Err() error

+ func (ci *CreateIndexes) Result() (result.CreateIndexes, error)

+ func (ci *CreateIndexes) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.CreateIndexes, error)

+ type Cursor interface

+ Close func(context.Context) error

+ Decode func(interface{}) error

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

+ Err func() error

+ ID func() int64

+ Next func(context.Context) bool

+ type CursorBuilder interface

+ BuildCursor func(bson.Raw, *session.Client, *session.ClusterClock, ...bsonx.Elem) (Cursor, error)

+ type Delete struct

+ Clock *session.ClusterClock

+ ContinueOnError bool

+ Deletes []bsonx.Doc

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (d *Delete) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Delete

+ func (d *Delete) Encode(desc description.SelectedServer) ([]wiremessage.WireMessage, error)

+ func (d *Delete) Err() error

+ func (d *Delete) Result() (result.Delete, error)

+ func (d *Delete) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.Delete, error)

+ type Distinct struct

+ Clock *session.ClusterClock

+ Field string

+ NS Namespace

+ Opts []bsonx.Elem

+ Query bsonx.Doc

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ func (d *Distinct) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Distinct

+ func (d *Distinct) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (d *Distinct) Err() error

+ func (d *Distinct) Result() (result.Distinct, error)

+ func (d *Distinct) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.Distinct, error)

+ type DropCollection struct

+ Clock *session.ClusterClock

+ Collection string

+ DB string

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (dc *DropCollection) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *DropCollection

+ func (dc *DropCollection) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (dc *DropCollection) Err() error

+ func (dc *DropCollection) Result() (bson.Raw, error)

+ func (dc *DropCollection) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Raw, error)

+ type DropDatabase struct

+ Clock *session.ClusterClock

+ DB string

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (dd *DropDatabase) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *DropDatabase

+ func (dd *DropDatabase) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (dd *DropDatabase) Err() error

+ func (dd *DropDatabase) Result() (bson.Raw, error)

+ func (dd *DropDatabase) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Raw, error)

+ type DropIndexes struct

+ Clock *session.ClusterClock

+ Index string

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (di *DropIndexes) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *DropIndexes

+ func (di *DropIndexes) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (di *DropIndexes) Err() error

+ func (di *DropIndexes) Result() (bson.Raw, error)

+ func (di *DropIndexes) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Raw, error)

+ type EndSessions struct

+ Clock *session.ClusterClock

+ SessionIDs []bsonx.Doc

+ func (es *EndSessions) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *EndSessions

+ func (es *EndSessions) Encode(desc description.SelectedServer) ([]wiremessage.WireMessage, error)

+ func (es *EndSessions) Result() ([]result.EndSessions, []error)

+ func (es *EndSessions) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) ([]result.EndSessions, []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) Retryable() bool

+ type Find struct

+ Clock *session.ClusterClock

+ CursorOpts []bsonx.Elem

+ Filter bsonx.Doc

+ NS Namespace

+ Opts []bsonx.Elem

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ func (f *Find) Decode(desc description.SelectedServer, cb CursorBuilder, wm wiremessage.WireMessage) *Find

+ func (f *Find) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (f *Find) Err() error

+ func (f *Find) Result() (Cursor, error)

+ func (f *Find) RoundTrip(ctx context.Context, desc description.SelectedServer, cb CursorBuilder, ...) (Cursor, error)

+ type FindOneAndDelete struct

+ Clock *session.ClusterClock

+ NS Namespace

+ Opts []bsonx.Elem

+ Query bsonx.Doc

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (f *FindOneAndDelete) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *FindOneAndDelete

+ func (f *FindOneAndDelete) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (f *FindOneAndDelete) Err() error

+ func (f *FindOneAndDelete) Result() (result.FindAndModify, error)

+ func (f *FindOneAndDelete) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.FindAndModify, error)

+ type FindOneAndReplace struct

+ Clock *session.ClusterClock

+ NS Namespace

+ Opts []bsonx.Elem

+ Query bsonx.Doc

+ Replacement bsonx.Doc

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (f *FindOneAndReplace) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *FindOneAndReplace

+ func (f *FindOneAndReplace) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (f *FindOneAndReplace) Err() error

+ func (f *FindOneAndReplace) Result() (result.FindAndModify, error)

+ func (f *FindOneAndReplace) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.FindAndModify, error)

+ type FindOneAndUpdate struct

+ Clock *session.ClusterClock

+ NS Namespace

+ Opts []bsonx.Elem

+ Query bsonx.Doc

+ Session *session.Client

+ Update bsonx.Doc

+ WriteConcern *writeconcern.WriteConcern

+ func (f *FindOneAndUpdate) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *FindOneAndUpdate

+ func (f *FindOneAndUpdate) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (f *FindOneAndUpdate) Err() error

+ func (f *FindOneAndUpdate) Result() (result.FindAndModify, error)

+ func (f *FindOneAndUpdate) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.FindAndModify, error)

+ type GetLastError struct

+ Clock *session.ClusterClock

+ Session *session.Client

+ func (gle *GetLastError) Decode(wm wiremessage.WireMessage) *GetLastError

+ func (gle *GetLastError) Encode() (wiremessage.WireMessage, error)

+ func (gle *GetLastError) Err() error

+ func (gle *GetLastError) Result() (result.GetLastError, error)

+ func (gle *GetLastError) RoundTrip(ctx context.Context, rw wiremessage.ReadWriter) (result.GetLastError, error)

+ type GetMore struct

+ Clock *session.ClusterClock

+ ID int64

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ func (gm *GetMore) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *GetMore

+ func (gm *GetMore) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (gm *GetMore) Err() error

+ func (gm *GetMore) Result() (bson.Raw, error)

+ func (gm *GetMore) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Raw, error)

+ type Handshake struct

+ Client bsonx.Doc

+ Compressors []string

+ SaslSupportedMechs string

+ func (h *Handshake) Decode(wm wiremessage.WireMessage) *Handshake

+ func (h *Handshake) Encode() (wiremessage.WireMessage, error)

+ func (h *Handshake) Err() error

+ func (h *Handshake) Handshake(ctx context.Context, addr address.Address, rw wiremessage.ReadWriter) (description.Server, error)

+ func (h *Handshake) Result(addr address.Address) (description.Server, error)

+ type Insert struct

+ Clock *session.ClusterClock

+ ContinueOnError bool

+ Docs []bsonx.Doc

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (i *Insert) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Insert

+ func (i *Insert) Encode(desc description.SelectedServer) ([]wiremessage.WireMessage, error)

+ func (i *Insert) Err() error

+ func (i *Insert) Result() (result.Insert, error)

+ func (i *Insert) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.Insert, error)

+ type IsMaster struct

+ Client bsonx.Doc

+ Compressors []string

+ SaslSupportedMechs string

+ func (im *IsMaster) Decode(wm wiremessage.WireMessage) *IsMaster

+ func (im *IsMaster) Encode() (wiremessage.WireMessage, error)

+ func (im *IsMaster) Err() error

+ func (im *IsMaster) Result() (result.IsMaster, error)

+ func (im *IsMaster) RoundTrip(ctx context.Context, rw wiremessage.ReadWriter) (result.IsMaster, error)

+ type KillCursors struct

+ Clock *session.ClusterClock

+ IDs []int64

+ NS Namespace

+ func (kc *KillCursors) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *KillCursors

+ func (kc *KillCursors) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (kc *KillCursors) Err() error

+ func (kc *KillCursors) Result() (result.KillCursors, error)

+ func (kc *KillCursors) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.KillCursors, error)

+ type ListCollections struct

+ Clock *session.ClusterClock

+ CursorOpts []bsonx.Elem

+ DB string

+ Filter bsonx.Doc

+ Opts []bsonx.Elem

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ func (lc *ListCollections) Decode(desc description.SelectedServer, cb CursorBuilder, wm wiremessage.WireMessage) *ListCollections

+ func (lc *ListCollections) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (lc *ListCollections) Err() error

+ func (lc *ListCollections) Result() (Cursor, error)

+ func (lc *ListCollections) RoundTrip(ctx context.Context, desc description.SelectedServer, cb CursorBuilder, ...) (Cursor, error)

+ type ListDatabases struct

+ Clock *session.ClusterClock

+ Filter bsonx.Doc

+ Opts []bsonx.Elem

+ Session *session.Client

+ func (ld *ListDatabases) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *ListDatabases

+ func (ld *ListDatabases) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (ld *ListDatabases) Err() error

+ func (ld *ListDatabases) Result() (result.ListDatabases, error)

+ func (ld *ListDatabases) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.ListDatabases, error)

+ type ListIndexes struct

+ Clock *session.ClusterClock

+ CursorOpts []bsonx.Elem

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ func (li *ListIndexes) Decode(desc description.SelectedServer, cb CursorBuilder, wm wiremessage.WireMessage) *ListIndexes

+ func (li *ListIndexes) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (li *ListIndexes) Err() error

+ func (li *ListIndexes) Result() (Cursor, error)

+ func (li *ListIndexes) RoundTrip(ctx context.Context, desc description.SelectedServer, cb CursorBuilder, ...) (Cursor, error)

+ type Namespace struct

+ Collection string

+ DB string

+ func NewNamespace(db, collection string) Namespace

+ func ParseNamespace(name string) Namespace

+ func (ns *Namespace) FullName() string

+ func (ns *Namespace) Validate() error

+ type QueryFailureError struct

+ Message string

+ Response bson.Raw

+ func (e QueryFailureError) Error() string

+ type Read struct

+ Clock *session.ClusterClock

+ Command bsonx.Doc

+ DB string

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ Session *session.Client

+ func (r *Read) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Read

+ func (r *Read) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (r *Read) Err() error

+ func (r *Read) Result() (bson.Raw, error)

+ func (r *Read) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Raw, error)

+ type ResponseError struct

+ Message string

+ Wrapped error

+ func NewCommandResponseError(msg string, err error) ResponseError

+ func (e ResponseError) Error() string

+ type StartSession struct

+ Clock *session.ClusterClock

+ func (ss *StartSession) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *StartSession

+ func (ss *StartSession) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (ss *StartSession) Err() error

+ func (ss *StartSession) Result() (result.StartSession, error)

+ func (ss *StartSession) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.StartSession, error)

+ type Update struct

+ Clock *session.ClusterClock

+ ContinueOnError bool

+ Docs []bsonx.Doc

+ NS Namespace

+ Opts []bsonx.Elem

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (u *Update) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Update

+ func (u *Update) Encode(desc description.SelectedServer) ([]wiremessage.WireMessage, error)

+ func (u *Update) Err() error

+ func (u *Update) Result() (result.Update, error)

+ func (u *Update) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (result.Update, error)

+ type Write struct

+ Clock *session.ClusterClock

+ Command bsonx.Doc

+ DB string

+ Session *session.Client

+ WriteConcern *writeconcern.WriteConcern

+ func (w *Write) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Write

+ func (w *Write) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error)

+ func (w *Write) Err() error

+ func (w *Write) Result() (bson.Raw, error)

+ func (w *Write) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Raw, error)

+ type WriteBatch struct

+ type WriteCommandKind int8

+ const DeleteCommand

+ const InsertCommand

+ const UpdateCommand

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