Documentation
¶
Index ¶
- Variables
- func Aggregate(ctx context.Context, cmd command.Aggregate, topo *topology.Topology, ...) (command.Cursor, error)
- func Command(ctx context.Context, cmd command.Command, topo *topology.Topology, ...) (bson.Reader, error)
- func Count(ctx context.Context, cmd command.Count, 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.Reader, error)
- func DropDatabase(ctx context.Context, cmd command.DropDatabase, topo *topology.Topology, ...) (bson.Reader, error)
- func DropIndexes(ctx context.Context, cmd command.DropIndexes, topo *topology.Topology, ...) (bson.Reader, 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 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 Update(ctx context.Context, cmd command.Update, topo *topology.Topology, ...) (result.Update, error)
Constants ¶
This section is empty.
Variables ¶
var ErrUnacknowledgedWrite = errors.New("unacknowledged write")
ErrUnacknowledgedWrite is returned from functions that have an unacknowledged write concern.
Functions ¶
func Aggregate ¶
func Aggregate( ctx context.Context, cmd command.Aggregate, topo *topology.Topology, readSelector, writeSelector description.ServerSelector, wc *writeconcern.WriteConcern, ) (command.Cursor, error)
Aggregate handles the full cycle dispatch and execution of an aggregate command against the provided topology.
func Command ¶
func Command( ctx context.Context, cmd command.Command, topo *topology.Topology, selector description.ServerSelector, ) (bson.Reader, error)
Command handles the full cycle dispatch and execution of a command against the provided topology.
func Count ¶
func Count( ctx context.Context, cmd command.Count, topo *topology.Topology, selector description.ServerSelector, rc *readconcern.ReadConcern, ) (int64, error)
Count handles the full cycle dispatch and execution of a count command against the provided topology.
func CreateIndexes ¶
func CreateIndexes( ctx context.Context, cmd command.CreateIndexes, topo *topology.Topology, selector description.ServerSelector, ) (result.CreateIndexes, error)
CreateIndexes handles the full cycle dispatch and execution of a createIndexes command against the provided topology.
func Delete ¶
func Delete( ctx context.Context, cmd command.Delete, topo *topology.Topology, selector description.ServerSelector, wc *writeconcern.WriteConcern, ) (result.Delete, error)
Delete handles the full cycle dispatch and execution of a delete command against the provided topology.
func Distinct ¶
func Distinct( ctx context.Context, cmd command.Distinct, topo *topology.Topology, selector description.ServerSelector, rc *readconcern.ReadConcern, ) (result.Distinct, error)
Distinct handles the full cycle dispatch and execution of a distinct command against the provided topology.
func DropCollection ¶ added in v0.0.4
func DropCollection( ctx context.Context, cmd command.DropCollection, topo *topology.Topology, selector description.ServerSelector, ) (bson.Reader, error)
DropCollection handles the full cycle dispatch and execution of a dropCollection command against the provided topology.
func DropDatabase ¶ added in v0.0.4
func DropDatabase( ctx context.Context, cmd command.DropDatabase, topo *topology.Topology, selector description.ServerSelector, ) (bson.Reader, error)
DropDatabase handles the full cycle dispatch and execution of a dropDatabase command against the provided topology.
func DropIndexes ¶
func DropIndexes( ctx context.Context, cmd command.DropIndexes, topo *topology.Topology, selector description.ServerSelector, ) (bson.Reader, error)
DropIndexes handles the full cycle dispatch and execution of a dropIndexes command against the provided topology.
func Find ¶
func Find( ctx context.Context, cmd command.Find, topo *topology.Topology, selector description.ServerSelector, rc *readconcern.ReadConcern, ) (command.Cursor, error)
Find handles the full cycle dispatch and execution of a find command against the provided topology.
func FindOneAndDelete ¶
func FindOneAndDelete( ctx context.Context, cmd command.FindOneAndDelete, topo *topology.Topology, selector description.ServerSelector, wc *writeconcern.WriteConcern, ) (result.FindAndModify, error)
FindOneAndDelete handles the full cycle dispatch and execution of a FindOneAndDelete command against the provided topology.
func FindOneAndReplace ¶
func FindOneAndReplace( ctx context.Context, cmd command.FindOneAndReplace, topo *topology.Topology, selector description.ServerSelector, wc *writeconcern.WriteConcern, ) (result.FindAndModify, error)
FindOneAndReplace handles the full cycle dispatch and execution of a FindOneAndReplace command against the provided topology.
func FindOneAndUpdate ¶
func FindOneAndUpdate( ctx context.Context, cmd command.FindOneAndUpdate, topo *topology.Topology, selector description.ServerSelector, wc *writeconcern.WriteConcern, ) (result.FindAndModify, error)
FindOneAndUpdate handles the full cycle dispatch and execution of a FindOneAndUpdate command against the provided topology.
func Insert ¶
func Insert( ctx context.Context, cmd command.Insert, topo *topology.Topology, selector description.ServerSelector, wc *writeconcern.WriteConcern, ) (result.Insert, error)
Insert handles the full cycle dispatch and execution of an insert command against the provided topology.
func ListCollections ¶
func ListCollections( ctx context.Context, cmd command.ListCollections, topo *topology.Topology, selector description.ServerSelector, ) (command.Cursor, error)
ListCollections handles the full cycle dispatch and execution of a listCollections command against the provided topology.
func ListDatabases ¶
func ListDatabases( ctx context.Context, cmd command.ListDatabases, topo *topology.Topology, selector description.ServerSelector, ) (result.ListDatabases, error)
ListDatabases handles the full cycle dispatch and execution of a listDatabases command against the provided topology.
func ListIndexes ¶
func ListIndexes( ctx context.Context, cmd command.ListIndexes, topo *topology.Topology, selector description.ServerSelector, ) (command.Cursor, error)
ListIndexes handles the full cycle dispatch and execution of a listIndexes command against the provided topology.
func Update ¶
func Update( ctx context.Context, cmd command.Update, topo *topology.Topology, selector description.ServerSelector, wc *writeconcern.WriteConcern, ) (result.Update, error)
Update handles the full cycle dispatch and execution of an update command against the provided topology.
Types ¶
This section is empty.
Source Files