dispatch

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Count handles the full cycle dispatch and execution of a count command against the provided topology.

func CreateIndexes

CreateIndexes handles the full cycle dispatch and execution of a createIndexes command against the provided topology.

func Delete

Delete handles the full cycle dispatch and execution of a delete command against the provided topology.

func Distinct

Distinct handles the full cycle dispatch and execution of a distinct 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

Find handles the full cycle dispatch and execution of a find command against the provided topology.

func FindOneAndDelete

FindOneAndDelete handles the full cycle dispatch and execution of a FindOneAndDelete command against the provided topology.

func FindOneAndReplace

FindOneAndReplace handles the full cycle dispatch and execution of a FindOneAndReplace command against the provided topology.

func FindOneAndUpdate

FindOneAndUpdate handles the full cycle dispatch and execution of a FindOneAndUpdate command against the provided topology.

func Insert

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

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

Update handles the full cycle dispatch and execution of an update command against the provided topology.

Types

This section is empty.

Jump to

Keyboard shortcuts

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