command

package

Go to main page

Versions in this module

v0

v0.0.18

Nov 15, 2018

Changes in this version

type Aggregate

+ CursorOpts []bsonx.Elem

type Find

+ CursorOpts []bsonx.Elem

type ListCollections

+ CursorOpts []bsonx.Elem

type ListIndexes

+ CursorOpts []bsonx.Elem

v0.0.17

Oct 25, 2018

v0.0.16

Oct 11, 2018

Changes in this version

type Delete

+ ContinueOnError bool

type Insert

+ ContinueOnError bool

type Update

+ ContinueOnError bool

+ type WriteBatch struct

+ type WriteCommandKind int8

+ const DeleteCommand

+ const InsertCommand

+ const UpdateCommand

v0.0.15

Sep 27, 2018

v0.0.14

Sep 20, 2018

v0.0.13

Sep 6, 2018

v0.0.12

Aug 16, 2018

Changes in this version

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

+ var NetworkError = "NetworkError"

+ var TransientTransactionError = "TransientTransactionError"

+ var UnknownTransactionCommitResult = "UnknownTransactionCommitResult"

+ func DecodeError(wm wiremessage.WireMessage) error

+ 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 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 Error

+ Labels []string

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

+ func (e Error) Retryable() bool

type Handshake

+ SaslSupportedMechs string

type IsMaster

+ SaslSupportedMechs string

v0.0.11

Aug 8, 2018

Changes in this version

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

+ type CountDocuments struct

+ Clock *session.ClusterClock

+ NS Namespace

+ Opts []option.CountOptioner

+ Pipeline *bson.Array

+ 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)

v0.0.10

Jul 26, 2018

Changes in this version

+ const BatchSize

type Aggregate

+ Clock *session.ClusterClock

+ Session *session.Client

type Count

+ Clock *session.ClusterClock

+ Session *session.Client

type CreateIndexes

+ Clock *session.ClusterClock

+ Session *session.Client

type Delete

+ Clock *session.ClusterClock

+ Session *session.Client

type Distinct

+ Clock *session.ClusterClock

+ Session *session.Client

type DropCollection

+ Clock *session.ClusterClock

+ Session *session.Client

type DropDatabase

+ Clock *session.ClusterClock

+ Session *session.Client

type DropIndexes

+ Clock *session.ClusterClock

+ Session *session.Client

+ type EndSessions struct

+ Clock *session.ClusterClock

+ SessionIDs []*bson.Document

+ 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 Find

+ Clock *session.ClusterClock

+ Session *session.Client

type FindOneAndDelete

+ Clock *session.ClusterClock

+ Session *session.Client

type FindOneAndReplace

+ Clock *session.ClusterClock

+ Session *session.Client

type FindOneAndUpdate

+ Clock *session.ClusterClock

+ Session *session.Client

type GetLastError

+ Clock *session.ClusterClock

+ Session *session.Client

type GetMore

+ Clock *session.ClusterClock

+ Session *session.Client

type Insert

+ Clock *session.ClusterClock

+ Session *session.Client

type KillCursors

+ Clock *session.ClusterClock

type ListCollections

+ Clock *session.ClusterClock

+ Session *session.Client

type ListDatabases

+ Clock *session.ClusterClock

+ Session *session.Client

type ListIndexes

+ Clock *session.ClusterClock

+ Session *session.Client

type Read

+ Clock *session.ClusterClock

+ Session *session.Client

+ 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

+ Clock *session.ClusterClock

+ Session *session.Client

type Write

+ Clock *session.ClusterClock

+ Session *session.Client

v0.0.9

Jul 10, 2018

Changes in this version

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

type Aggregate

+ ReadConcern *readconcern.ReadConcern

+ WriteConcern *writeconcern.WriteConcern

type Count

+ ReadConcern *readconcern.ReadConcern

type CreateIndexes

+ WriteConcern *writeconcern.WriteConcern

type Delete

+ WriteConcern *writeconcern.WriteConcern

type Distinct

+ ReadConcern *readconcern.ReadConcern

type DropCollection

+ WriteConcern *writeconcern.WriteConcern

type DropDatabase

+ WriteConcern *writeconcern.WriteConcern

type DropIndexes

+ WriteConcern *writeconcern.WriteConcern

type Find

+ ReadConcern *readconcern.ReadConcern

type FindOneAndDelete

+ WriteConcern *writeconcern.WriteConcern

type FindOneAndReplace

+ WriteConcern *writeconcern.WriteConcern

type FindOneAndUpdate

+ WriteConcern *writeconcern.WriteConcern

type Insert

+ WriteConcern *writeconcern.WriteConcern

type ListCollections

+ ReadPref *readpref.ReadPref

+ type Read struct

+ Command *bson.Document

+ DB string

+ ReadConcern *readconcern.ReadConcern

+ ReadPref *readpref.ReadPref

+ 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.Reader, error)

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

type Update

+ WriteConcern *writeconcern.WriteConcern

+ type Write struct

+ Command *bson.Document

+ DB string

+ 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.Reader, error)

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

v0.0.8

Jun 25, 2018

Changes in this version

type Handshake

+ Compressors []string

type IsMaster

+ Compressors []string

v0.0.7

Jun 12, 2018

v0.0.6

May 31, 2018

v0.0.5

May 17, 2018

Changes in this version

type CreateIndexes

+ Opts []options.CreateIndexesOptioner

type DropIndexes

+ Opts []options.DropIndexesOptioner

v0.0.4

May 2, 2018

Changes in this version

+ type DropCollection struct

+ Collection string

+ DB string

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

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

+ func (di *DropCollection) Err() error

+ func (di *DropCollection) Result() (bson.Reader, error)

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

+ type DropDatabase struct

+ DB string

+ 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.Reader, error)

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

v0.0.3

Apr 18, 2018

Changes in this version

+ 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 ErrUnknownCommandFailure = errors.New("unknown command failure")

+ func ClientDoc(app string) *bson.Document

+ func IsNotFound(err error) bool

+ type Aggregate struct

+ NS Namespace

+ Opts []options.AggregateOptioner

+ Pipeline *bson.Array

+ ReadPref *readpref.ReadPref

+ 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 Command struct

+ Command interface{}

+ DB string

+ ReadPref *readpref.ReadPref

+ func (c *Command) Decode(_ description.SelectedServer, wm wiremessage.WireMessage) *Command

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

+ func (c *Command) Err() error

+ func (c *Command) Result() (bson.Reader, error)

+ func (c *Command) RoundTrip(ctx context.Context, desc description.SelectedServer, ...) (bson.Reader, error)

+ type Count struct

+ NS Namespace

+ Opts []options.CountOptioner

+ Query *bson.Document

+ ReadPref *readpref.ReadPref

+ 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 CreateIndexes struct

+ Indexes *bson.Array

+ NS Namespace

+ 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.Reader, error)

+ Err func() error

+ ID func() int64

+ Next func(context.Context) bool

+ type CursorBuilder interface

+ BuildCursor func(bson.Reader, ...options.CursorOptioner) (Cursor, error)

+ type Delete struct

+ Deletes []*bson.Document

+ NS Namespace

+ Opts []options.DeleteOptioner

+ 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

+ Field string

+ NS Namespace

+ Opts []options.DistinctOptioner

+ Query *bson.Document

+ ReadPref *readpref.ReadPref

+ 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 DropIndexes struct

+ Index string

+ NS Namespace

+ 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.Reader, error)

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

+ type Error struct

+ Code int32

+ Message string

+ Name string

+ func (e Error) Error() string

+ type Find struct

+ Filter *bson.Document

+ NS Namespace

+ Opts []options.FindOptioner

+ ReadPref *readpref.ReadPref

+ 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

+ NS Namespace

+ Opts []options.FindOneAndDeleteOptioner

+ Query *bson.Document

+ 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

+ NS Namespace

+ Opts []options.FindOneAndReplaceOptioner

+ Query *bson.Document

+ Replacement *bson.Document

+ 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

+ NS Namespace

+ Opts []options.FindOneAndUpdateOptioner

+ Query *bson.Document

+ Update *bson.Document

+ 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

+ 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

+ ID int64

+ NS Namespace

+ Opts []options.CursorOptioner

+ 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.Reader, error)

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

+ type Handshake struct

+ Client *bson.Document

+ func (h *Handshake) Decode(wms [2]wiremessage.WireMessage) *Handshake

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

+ func (h *Handshake) Err() error

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

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

+ type Insert struct

+ Docs []*bson.Document

+ NS Namespace

+ Opts []options.InsertOptioner

+ 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 *bson.Document

+ 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

+ 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

+ DB string

+ Filter *bson.Document

+ Opts []options.ListCollectionsOptioner

+ 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

+ Filter *bson.Document

+ Opts []options.ListDatabasesOptioner

+ 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

+ NS Namespace

+ Opts []options.ListIndexesOptioner

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

+ 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 Update struct

+ Docs []*bson.Document

+ NS Namespace

+ Opts []options.UpdateOptioner

+ 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)

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