nosql

Aug 21, 2023

Changes in this version

+ type Aggregater interface

+ Aggregate func(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)

type ManyResult

+ func AggregateMany(ctx context.Context, aggregater Aggregater, pipeline interface{}, ...) *ManyResult

Jul 23, 2023

Changes in this version

type Collection

+ func (c *Collection) AggregateMany(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) *ManyResult

Nov 12, 2020

Changes in this version

+ type Finder interface

+ Find func(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error)

type ManyResult

+ func FindMany(ctx context.Context, finder Finder, filter interface{}, ...) *ManyResult

Dec 15, 2019

Changes in this version

+ type Collection struct

+ func (c *Collection) FindMany(ctx context.Context, filter interface{}, opts ...*options.FindOptions) *ManyResult

+ type Database struct

+ func NewDatabase(db *mongo.Database) *Database

+ func (db *Database) Collection(name string, opts ...*options.CollectionOptions) *Collection

+ func (db *Database) InitSequence(ctx context.Context, idName string, idValue int64) error

+ func (db *Database) NextSequence(ctx context.Context, idName string) (int64, error)

+ func (db *Database) NextSequences(ctx context.Context, idName string, size int64) (int64, error)

+ type Databases struct

+ func Open(ini IniFile, opts ...*options.ClientOptions) *Databases

+ func (d *Databases) Close(ctx context.Context) error

+ func (d *Databases) Get(ctx context.Context, name string, dbopts ...*options.DatabaseOptions) (*Database, error)

+ type IniFile interface

+ Get func(section string, name string) string

+ type ManyResult struct

+ func (a *ManyResult) Cursor() *mongo.Cursor

+ func (a *ManyResult) Decode(data interface{}) error

+ func (a *ManyResult) Err() error