command

package

Go to main page

Versions in this module

v0

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