mongo

Oct 24, 2024

Changes in this version

type Collection

+ func (c *Collection) Get() *mongo.Collection

type Database

+ func (d *Database) Get() *mongo.Database

type Session

+ func (s *Session) GetCollection() *mongo.Collection

+ func (s *Session) GetTable() *Collection

Oct 24, 2024

Changes in this version

+ type Client = mongo.Client

+ type Cursor = mongo.Cursor

+ type SessionContext = mongo.SessionContext

Sep 1, 2024

Changes in this version

+ func Close(uri ...string) error

Sep 1, 2024

Changes in this version

type Session

+ func GetSession(uri string) (*Session, error)

+ func (s *Session) Close()

+ func (s *Session) Release()

Aug 14, 2024

Changes in this version

+ var ErrNoDocuments = mongo.ErrNoDocuments

Mar 13, 2024

Changes in this version

+ var ErrMongoNoDoc = errors.New("mongo: no document results")

+ type BulkWriteResult = mongo.BulkWriteResult

+ type Collection struct

+ func C(collection string) *Collection

+ func (c *Collection) Aggregate(pipeline any, results any, opts ...*options.AggregateOptions) error

+ func (c *Collection) FindByID(id primitive.ObjectID, result any) error

+ func (c *Collection) Index(keys ...bson.M) ([]string, error)

+ func (c *Collection) Insert(doc any, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

+ func (c *Collection) InsertAll(docs []any, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)

+ func (c *Collection) Where(filter bson.D) *Session

+ type CollectionSpecification = mongo.CollectionSpecification

+ type Database struct

+ func (d *Database) C(collection string) *Collection

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

+ func (d *Database) CollectionNames() ([]string, error)

+ type DatabaseSpecification = mongo.DatabaseSpecification

+ type DeleteResult = mongo.DeleteResult

+ type IndexSpecification = mongo.IndexSpecification

+ type InsertManyResult = mongo.InsertManyResult

+ type InsertOneResult = mongo.InsertOneResult

+ type ListDatabasesResult = mongo.ListDatabasesResult

+ type Pipeline = mongo.Pipeline

+ type RewrapManyDataKeyResult = mongo.RewrapManyDataKeyResult

+ type Session struct

+ func Get(uri ...string) *Session

+ func New(uri ...string) *Session

+ func (s *Session) C(collection string) *Collection

+ func (s *Session) Client() *mongo.Client

+ func (s *Session) Collection(collection string) *Collection

+ func (s *Session) Connect() error

+ func (s *Session) Count(opts ...*options.CountOptions) int64

+ func (s *Session) DB(db string) *Database

+ func (s *Session) FetchAll(results any) error

+ func (s *Session) Find(result any) error

+ func (s *Session) Pagination(page, limit int, results any) (int64, error)

+ func (s *Session) Ping() error

+ func (s *Session) Remove(opts ...*options.DeleteOptions) error

+ func (s *Session) RemoveID(id primitive.ObjectID, opts ...*options.DeleteOptions) error

+ func (s *Session) RemoveOne(opts ...*options.DeleteOptions) error

+ func (s *Session) Run(size int32, callback func(*mongo.Cursor)) error

+ func (s *Session) SetOpts(opts ...*options.FindOptions) *Session

+ func (s *Session) Update(update any, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ func (s *Session) UpdateID(id primitive.ObjectID, update any, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ func (s *Session) UpdateOne(update any, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ type UpdateResult = mongo.UpdateResult