qmgo

May 25, 2023

Changes in this version

type Aggregate

+ func (a *Aggregate) Cursor() CursorI

type AggregateI

+ Cursor func() CursorI

Jan 20, 2023

Changes in this version

type Query

+ func (q *Query) SetArrayFilters(filter *options.ArrayFilters) QueryI

type QueryI

+ SetArrayFilters func(*options.ArrayFilters) QueryI

Oct 4, 2022

Changes in this version

type Bulk

+ func (b *Bulk) UpsertOne(filter interface{}, update interface{}) *Bulk

Aug 28, 2022

Changes in this version

type Query

+ func (q *Query) Collation(collation *options.Collation) QueryI

type QueryI

+ Collation func(collation *options.Collation) QueryI

Jul 6, 2022

Changes in this version

type Query

+ func (q *Query) EstimatedCount() (n int64, err error)

+ func (q *Query) NoCursorTimeout(n bool) QueryI

type QueryI

+ EstimatedCount func() (n int64, err error)

+ NoCursorTimeout func(n bool) QueryI

Apr 9, 2022

Changes in this version

type Query

+ func (q *Query) BatchSize(n int64) QueryI

type QueryI

+ BatchSize func(n int64) QueryI

Oct 22, 2021

Changes in this version

type Database

+ func (db *Database) CreateCollection(ctx context.Context, name string, opts ...opts.CreateCollectionOptions) error

Sep 3, 2021

Changes in this version

+ type A = bson.A

+ type D = bson.D

+ type E = bson.E

+ type M = bson.M

Aug 28, 2021

Changes in this version

type Collection

+ func (c *Collection) Watch(ctx context.Context, pipeline interface{}, opts ...*opts.ChangeStreamOptions) (*mongo.ChangeStream, error)

Mar 13, 2021

Changes in this version

+ type Bulk struct

+ func (b *Bulk) InsertOne(doc interface{}) *Bulk

+ func (b *Bulk) Remove(filter interface{}) *Bulk

+ func (b *Bulk) RemoveAll(filter interface{}) *Bulk

+ func (b *Bulk) RemoveId(id interface{}) *Bulk

+ func (b *Bulk) Run(ctx context.Context) (*BulkResult, error)

+ func (b *Bulk) SetOrdered(ordered bool) *Bulk

+ func (b *Bulk) UpdateAll(filter interface{}, update interface{}) *Bulk

+ func (b *Bulk) UpdateId(id interface{}, update interface{}) *Bulk

+ func (b *Bulk) UpdateOne(filter interface{}, update interface{}) *Bulk

+ func (b *Bulk) Upsert(filter interface{}, replacement interface{}) *Bulk

+ func (b *Bulk) UpsertId(id interface{}, replacement interface{}) *Bulk

+ type BulkResult struct

+ DeletedCount int64

+ InsertedCount int64

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedCount int64

+ UpsertedIDs map[int64]interface{}

type Collection

+ func (c *Collection) Bulk() *Bulk

Dec 13, 2020

Changes in this version

type Collection

+ func (c *Collection) DropAllIndexes(ctx context.Context) (err error)

type Database

+ func (d *Database) RunCommand(ctx context.Context, runCommand interface{}, opts ...opts.RunCommandOptions) *mongo.SingleResult

Oct 27, 2020

Changes in this version

type Collection

+ func (c *Collection) UpdateId(ctx context.Context, id interface{}, update interface{}, ...) (err error)

+ func (c *Collection) UpsertId(ctx context.Context, id interface{}, replacement interface{}, ...) (result *UpdateResult, err error)

type Query

+ func (q *Query) Hint(hint interface{}) QueryI

type QueryI

+ Hint func(hint interface{}) QueryI

Sep 27, 2020

Changes in this version

+ var ErrReplacementContainUpdateOperators = errors.New("replacement document cannot contain keys beginning with '$'")

+ type Change struct

+ Remove bool

+ Replace bool

+ ReturnNew bool

+ Update interface{}

+ Upsert bool

type Query

+ func (q *Query) Apply(change Change, result interface{}) error

type QueryI

+ Apply func(change Change, result interface{}) error

Sep 19, 2020

Changes in this version

type Collection

+ func (c *Collection) CreateIndexes(ctx context.Context, indexes []opts.IndexModel) (err error)

+ func (c *Collection) CreateOneIndex(ctx context.Context, indexes opts.IndexModel) error

+ func (c *Collection) DropIndex(ctx context.Context, indexes []string) error

Sep 19, 2020

Changes in this version

type Collection

+ func (c *Collection) ReplaceOne(ctx context.Context, filter interface{}, doc interface{}, ...) (err error)

Sep 13, 2020

Changes in this version

type Collection

+ func (c *Collection) UpdateWithDocument(ctx context.Context, filter interface{}, doc interface{}, ...) (err error)

Aug 31, 2020

Changes in this version

+ var ErrNotValidSliceToInsert = errors.New("must be valid slice to insert")

type Collection

+ func (c *Collection) RemoveAll(ctx context.Context, filter interface{}, opts ...qOpts.RemoveOptions) (result *DeleteResult, err error)

Aug 23, 2020

Changes in this version

+ var ErrNotSupportedPassword = errors.New("password not supported")

+ var ErrNotSupportedUsername = errors.New("username not supported")

Aug 20, 2020

Changes in this version

type Collection

+ func (c *Collection) DropIndexes(ctx context.Context, indexes []string) error

type Config

+ Auth *Credential

+ type Credential struct

+ AuthMechanism string

+ AuthSource string

+ Password string

+ PasswordSet bool

+ Username string

Aug 16, 2020

Changes in this version

+ var ErrTransactionNotSupported = errors.New("transaction not supported")

+ var ErrTransactionRetry = errors.New("retry transaction")

+ func CompareVersions(v1 string, v2 string) (int, error)

type Client

+ func (c *Client) DoTransaction(ctx context.Context, ...) (interface{}, error)

+ func (c *Client) ServerVersion() string

+ func (c *Client) Session() (*Session, error)

type Config

+ MinPoolSize *uint64

+ PoolMonitor *event.PoolMonitor

+ ReadPreference *ReadPref

+ type ReadPref struct

+ MaxStalenessMS int64

+ Mode readpref.Mode

+ type Session struct

+ func (s *Session) AbortTransaction(ctx context.Context) error

+ func (s *Session) EndSession(ctx context.Context)

+ func (s *Session) StartTransaction(ctx context.Context, cb func(sessCtx context.Context) (interface{}, error)) (interface{}, error)

Aug 12, 2020

Changes in this version

+ func IsErrNoDocuments(err error) bool

+ func NewObjectID() primitive.ObjectID

type Collection

+ func (c *Collection) RemoveId(ctx context.Context, id string) (err error)

Aug 11, 2020

Changes in this version

type Collection

+ func (c *Collection) UpdateOne(ctx context.Context, filter interface{}, update interface{}) error

Aug 10, 2020

Changes in this version

+ var ErrNoSuchDocuments = errors.New(mongo.ErrNoDocuments.Error())

+ var ErrQueryNotSlicePointer = errors.New("result argument must be a pointer to a slice")

+ var ErrQueryNotSliceType = errors.New("result argument must be a slice address")

+ var ErrQueryResultTypeInconsistent = errors.New("result type is not equal mongodb value type")

+ var ErrQueryResultValCanNotChange = errors.New("the value of result can not be changed")

+ func Now() time.Time

Aug 7, 2020

Changes in this version

+ var ERR_NO_SUCH_RECORD = errors.New("no such record")

+ var ERR_QUERY_NOT_SLICE_POINTER = errors.New("result argument must be a pointer to a slice")

+ var ERR_QUERY_NOT_SLICE_TYPE = errors.New("result argument must be a slice address")

+ var ERR_QUERY_RESULT_TYPE_INCONSISTEN = errors.New("result type is not equal mongodb value type")

+ var ERR_QUERY_RESULT_VAL_CAN_NOT_CHANGE = errors.New("the value of result can not be changed")

+ func IsDup(err error) bool

+ func SplitSortField(field string) (key string, sort int32)

+ type Aggregate struct

+ func (a *Aggregate) All(results interface{}) error

+ func (a *Aggregate) Iter() CursorI

+ func (a *Aggregate) One(result interface{}) error

+ type AggregateI interface

+ All func(results interface{}) error

+ Iter func() CursorI

+ One func(result interface{}) error

+ type Client struct

+ func NewClient(ctx context.Context, conf *Config) (cli *Client, err error)

+ func (c *Client) Close(ctx context.Context) error

+ func (c *Client) Database(name string) *Database

+ func (c *Client) Ping(timeout int64) error

+ type Collection struct

+ func (c *Collection) Aggregate(ctx context.Context, pipeline interface{}) AggregateI

+ func (c *Collection) CloneCollection() (*mongo.Collection, error)

+ func (c *Collection) DeleteAll(ctx context.Context, filter interface{}) (result *DeleteResult, err error)

+ func (c *Collection) DropCollection(ctx context.Context) error

+ func (c *Collection) EnsureIndexes(ctx context.Context, uniques []string, indexes []string)

+ func (c *Collection) Find(ctx context.Context, filter interface{}) QueryI

+ func (c *Collection) GetCollectionName() string

+ func (c *Collection) InsertMany(ctx context.Context, docs []interface{}) (result *InsertManyResult, err error)

+ func (c *Collection) InsertOne(ctx context.Context, doc interface{}) (result *InsertOneResult, err error)

+ func (c *Collection) Remove(ctx context.Context, filter interface{}) (err error)

+ func (c *Collection) Update(ctx context.Context, filter interface{}, update interface{}) error

+ func (c *Collection) UpdateAll(ctx context.Context, filter interface{}, update interface{}) (result *UpdateResult, err error)

+ func (c *Collection) Upsert(ctx context.Context, filter interface{}, replacement interface{}) (result *UpdateResult, err error)

+ type Config struct

+ Coll string

+ ConnectTimeoutMS *int64

+ Database string

+ MaxPoolSize *uint64

+ SocketTimeoutMS *int64

+ Uri string

+ type Cursor struct

+ func (c *Cursor) All(results interface{}) error

+ func (c *Cursor) Close() error

+ func (c *Cursor) Err() error

+ func (c *Cursor) Next(result interface{}) bool

+ type CursorI interface

+ All func(reuslts interface{}) error

+ Close func() error

+ Err func() error

+ Next func(result interface{}) bool

+ type Database struct

+ func NewDatabase(ctx context.Context, conf *Config) (cli *Database, err error)

+ func (d *Database) Collection(name string) *Collection

+ func (d *Database) DropDatabase(ctx context.Context)

+ func (d *Database) GetDatabaseName() string

+ type DeleteResult struct

+ DeletedCount int64

+ type InsertManyResult struct

+ InsertedIDs []interface{}

+ type InsertOneResult struct

+ InsertedID interface{}

+ type Pipeline []bson.D

+ type QmgoClient struct

+ func Open(ctx context.Context, conf *Config) (cli *QmgoClient, err error)

+ type Query struct

+ func (q *Query) All(result interface{}) error

+ func (q *Query) Count() (n int64, err error)

+ func (q *Query) Cursor() CursorI

+ func (q *Query) Distinct(key string, result interface{}) error

+ func (q *Query) Limit(n int64) QueryI

+ func (q *Query) One(result interface{}) error

+ func (q *Query) Select(projection interface{}) QueryI

+ func (q *Query) Skip(n int64) QueryI

+ func (q *Query) Sort(fields ...string) QueryI

+ type QueryI interface

+ All func(result interface{}) error

+ Count func() (n int64, err error)

+ Cursor func() CursorI

+ Distinct func(key string, result interface{}) error

+ Limit func(n int64) QueryI

+ One func(result interface{}) error

+ Select func(selector interface{}) QueryI

+ Skip func(n int64) QueryI

+ Sort func(fields ...string) QueryI

+ type UpdateResult struct

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedCount int64

+ UpsertedID interface{}