Documentation ¶
Index ¶
- 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 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.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 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 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.Reader, 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.Reader, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AbortTransaction ¶
func AbortTransaction( ctx context.Context, cmd command.AbortTransaction, topo *topology.Topology, selector description.ServerSelector, ) (result.TransactionResult, error)
AbortTransaction handles the full cycle dispatch and execution of abortting a transaction against the provided topology.
func Aggregate ¶
func Aggregate( ctx context.Context, cmd command.Aggregate, topo *topology.Topology, readSelector, writeSelector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (command.Cursor, error)
Aggregate handles the full cycle dispatch and execution of an aggregate command against the provided topology.
func CommitTransaction ¶
func CommitTransaction( ctx context.Context, cmd command.CommitTransaction, topo *topology.Topology, selector description.ServerSelector, ) (result.TransactionResult, error)
CommitTransaction handles the full cycle dispatch and execution of committing a transaction against the provided topology.
func Count ¶
func Count( ctx context.Context, cmd command.Count, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (int64, error)
Count handles the full cycle dispatch and execution of a count command against the provided topology.
func CountDocuments ¶
func CountDocuments( ctx context.Context, cmd command.CountDocuments, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (int64, error)
CountDocuments handles the full cycle dispatch and execution of a countDocuments command against the provided topology.
func CreateIndexes ¶
func CreateIndexes( ctx context.Context, cmd command.CreateIndexes, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (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, clientID uuid.UUID, pool *session.Pool, retryWrite bool, ) (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, clientID uuid.UUID, pool *session.Pool, ) (result.Distinct, error)
Distinct handles the full cycle dispatch and execution of a distinct command against the provided topology.
func DropCollection ¶
func DropCollection( ctx context.Context, cmd command.DropCollection, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (bson.Reader, error)
DropCollection handles the full cycle dispatch and execution of a dropCollection command against the provided topology.
func DropDatabase ¶
func DropDatabase( ctx context.Context, cmd command.DropDatabase, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (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, clientID uuid.UUID, pool *session.Pool, ) (bson.Reader, error)
DropIndexes handles the full cycle dispatch and execution of a dropIndexes command against the provided topology.
func EndSessions ¶
func EndSessions( ctx context.Context, cmd command.EndSessions, topo *topology.Topology, selector description.ServerSelector, ) ([]result.EndSessions, []error)
EndSessions handles the full cycle dispatch and execution of an endSessions command against the provided topology.
func Find ¶
func Find( ctx context.Context, cmd command.Find, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (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, clientID uuid.UUID, pool *session.Pool, retryWrite bool, ) (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, clientID uuid.UUID, pool *session.Pool, retryWrite bool, ) (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, clientID uuid.UUID, pool *session.Pool, retryWrite bool, ) (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, clientID uuid.UUID, pool *session.Pool, retryWrite bool, ) (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, clientID uuid.UUID, pool *session.Pool, ) (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, clientID uuid.UUID, pool *session.Pool, ) (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, clientID uuid.UUID, pool *session.Pool, ) (command.Cursor, error)
ListIndexes handles the full cycle dispatch and execution of a listIndexes command against the provided topology.
func Read ¶
func Read( ctx context.Context, cmd command.Read, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, ) (bson.Reader, error)
Read handles the full cycle dispatch and execution of a read command against the provided topology.
func Update ¶
func Update( ctx context.Context, cmd command.Update, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, retryWrite bool, ) (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 ¶
- abort_transaction.go
- aggregate.go
- commit_transaction.go
- count.go
- count_documents.go
- create_indexes.go
- delete.go
- delete_indexes.go
- distinct.go
- drop_collection.go
- drop_database.go
- end_sessions.go
- find.go
- find_one_and_delete.go
- find_one_and_replace.go
- find_one_and_update.go
- insert.go
- list_collections.go
- list_databases.go
- list_indexes.go
- read.go
- update.go
- write.go