Versions in this module Expand all Collapse all v0 v0.0.2 Mar 6, 2018 Changes in this version + func KillCursors(ctx context.Context, s *SelectedServer, ns Namespace, cursors []int64) (bson.Reader, error) type Cursor + DecodeBytes func() (bson.Reader, error) + ID func() int64 v0.0.1 Feb 13, 2018 Changes in this version + func Count(ctx context.Context, s *SelectedServer, ns Namespace, ...) (int64, error) + func Delete(ctx context.Context, s *SelectedServer, ns Namespace, ...) (bson.Reader, error) + func Distinct(ctx context.Context, s *SelectedServer, ns Namespace, ...) ([]interface{}, error) + func Insert(ctx context.Context, s *SelectedServer, ns Namespace, ...) (rdr bson.Reader, err error) + func Run(ctx context.Context, s *SelectedServer, db string, command interface{}) (bson.Reader, error) + func RunCommand(ctx context.Context, s *SelectedServer, db string, command interface{}) (bson.Reader, error) + func Update(ctx context.Context, s *SelectedServer, ns Namespace, ...) (bson.Reader, error) + type AggregationOptions struct + AllowDiskUse bool + BatchSize int32 + MaxTime time.Duration + type Cursor interface + Close func(context.Context) error + Decode func(interface{}) error + Err func() error + Next func(context.Context) bool + func Aggregate(ctx context.Context, s *SelectedServer, ns Namespace, ...) (Cursor, error) + func Find(ctx context.Context, s *SelectedServer, ns Namespace, ...) (Cursor, error) + func FindOneAndDelete(ctx context.Context, s *SelectedServer, ns Namespace, ...) (Cursor, error) + func FindOneAndReplace(ctx context.Context, s *SelectedServer, ns Namespace, ...) (Cursor, error) + func FindOneAndUpdate(ctx context.Context, s *SelectedServer, ns Namespace, ...) (Cursor, error) + func LegacyAggregate(ctx context.Context, s *SelectedServer, ns Namespace, pipeline *bson.Array, ...) (Cursor, error) + func ListCollections(ctx context.Context, s *SelectedServer, db string, ...) (Cursor, error) + func ListDatabases(ctx context.Context, s *SelectedServer, options ListDatabasesOptions) (Cursor, error) + func ListIndexes(ctx context.Context, s *SelectedServer, ns Namespace, ...) (Cursor, error) + func NewCursor(cursorResult bson.Reader, batchSize int32, server Server) (Cursor, error) + func NewExhaustedCursor() (Cursor, error) + type ListCollectionsOptions struct + BatchSize int32 + Filter interface{} + MaxTime time.Duration + type ListDatabasesOptions struct + MaxTime time.Duration + type ListIndexesOptions struct + BatchSize int32 + type Namespace struct + Collection string + DB string + func NewNamespace(db, collection string) Namespace + func ParseNamespace(fullName string) Namespace + func (ns *Namespace) FullName() string + type SelectedServer struct + ClusterKind model.ClusterKind + ReadPref *readpref.ReadPref + type Server interface + Connection func(context.Context) (conn.Connection, error) + Model func() *model.Server
Go to main page