lungo

Feb 19, 2024

Changes in this version

type Collection

+ func (c *Collection) SearchIndexes() mongo.SearchIndexView

type Cursor

+ func (c *Cursor) SetComment(interface{})

+ func (c *Cursor) SetMaxTime(time.Duration)

type IChangeStream

+ SetBatchSize func(int32)

type ICollection

+ SearchIndexes func() mongo.SearchIndexView

type ICursor

+ SetComment func(interface{})

+ SetMaxTime func(time.Duration)

type ISingleResult

+ Raw func() (bson.Raw, error)

type SingleResult

+ func (r *SingleResult) Raw() (bson.Raw, error)

type Stream

+ func (s *Stream) SetBatchSize(int32)

Jun 12, 2023

Changes in this version

type Client

+ func (c *Client) Timeout() *time.Duration

type Cursor

+ func (c *Cursor) SetBatchSize(int32)

type IClient

+ Timeout func() *time.Duration

type ICursor

+ SetBatchSize func(batchSize int32)

May 11, 2022

Changes in this version

+ var ErrNegativePosition = errors.New("negative position")

Apr 28, 2021

Changes in this version

type Collection

+ func (c *Collection) UpdateByID(ctx context.Context, id interface{}, update interface{}, ...) (*mongo.UpdateResult, error)

type Database

+ func (d *Database) ListCollectionSpecifications(context.Context, interface{}, ...*options.ListCollectionsOptions) ([]*mongo.CollectionSpecification, error)

type ICollection

+ UpdateByID func(context.Context, interface{}, interface{}, ...*options.UpdateOptions) (*mongo.UpdateResult, error)

type IDatabase

+ ListCollectionSpecifications func(context.Context, interface{}, ...*options.ListCollectionsOptions) ([]*mongo.CollectionSpecification, error)

type IIndexView

+ ListSpecifications func(context.Context, ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)

type IndexView

+ func (v *IndexView) ListSpecifications(context.Context, ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)

Aug 6, 2020

Changes in this version

+ var ErrLostOplogPosition = errors.New("lost oplog position")

type Bucket

+ func (b *Bucket) GetChunksCollection(_ context.Context) ICollection

+ func (b *Bucket) GetFilesCollection(_ context.Context) ICollection

+ func (b *Bucket) GetMarkersCollection(_ context.Context) ICollection

type Cursor

+ func (c *Cursor) RemainingBatchLength() int

type Database

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

+ func (d *Database) CreateView(_ context.Context, _, _ string, _ interface{}, _ ...*options.CreateViewOptions) error

type DownloadStream

+ func (s *DownloadStream) GetFile() *BucketFile

type ICursor

+ RemainingBatchLength func() int

type IDatabase

+ CreateCollection func(context.Context, string, ...*options.CreateCollectionOptions) error

+ CreateView func(context.Context, string, string, interface{}, ...*options.CreateViewOptions) error

type ISession

+ ID func() bson.Raw

type MongoDatabase

+ func (d *MongoDatabase) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error

type MongoIndexView

+ func (m *MongoIndexView) CreateMany(ctx context.Context, models []mongo.IndexModel, ...) ([]string, error)

+ func (m *MongoIndexView) CreateOne(ctx context.Context, model mongo.IndexModel, ...) (string, error)

+ func (m *MongoIndexView) DropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (bson.Raw, error)

+ func (m *MongoIndexView) DropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (bson.Raw, error)

type MongoSession

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

+ func (s *MongoSession) CommitTransaction(ctx context.Context) error

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

type Options

+ MinOplogAge time.Duration

+ MinOplogSize int

type Session

+ func (s *Session) ID() bson.Raw

type Transaction

+ func (t *Transaction) Create(handle Handle) error

May 25, 2020

Changes in this version

+ var ErrInvalidPosition = errors.New("invalid position")

Mar 3, 2020

Changes in this version

type Operation

+ ArrayFilters bsonkit.List

Jan 21, 2020

Changes in this version

+ const BucketMarkerStateDeleted

+ const BucketMarkerStateUploaded

+ const BucketMarkerStateUploading

type Bucket

+ func (b *Bucket) ClaimUpload(ctx context.Context, id interface{}) error

+ func (b *Bucket) Cleanup(ctx context.Context, age time.Duration) error

+ func (b *Bucket) EnableTracking()

+ func (b *Bucket) EnsureIndexes(ctx context.Context, force bool) error

+ type BucketMarker struct

+ ChunkSize int

+ File interface{}

+ Filename string

+ ID primitive.ObjectID

+ Length int

+ Metadata interface{}

+ State string

+ Timestamp time.Time

type UploadStream

+ func (s *UploadStream) Resume() (int64, error)

+ func (s *UploadStream) Suspend() (int64, error)

Jan 17, 2020

Changes in this version

+ var ErrFileNotFound = gridfs.ErrFileNotFound

+ var ErrNoDocuments = mongo.ErrNoDocuments

+ type Bucket struct

+ func NewBucket(db IDatabase, opts ...*options.BucketOptions) *Bucket

+ func (b *Bucket) Delete(ctx context.Context, id interface{}) error

+ func (b *Bucket) DownloadToStream(ctx context.Context, id interface{}, w io.Writer) (int64, error)

+ func (b *Bucket) DownloadToStreamByName(ctx context.Context, name string, w io.Writer, opts ...*options.NameOptions) (int64, error)

+ func (b *Bucket) Drop(ctx context.Context) error

+ func (b *Bucket) Find(ctx context.Context, filter interface{}, opts ...*options.GridFSFindOptions) (ICursor, error)

+ func (b *Bucket) OpenDownloadStream(ctx context.Context, id interface{}) (*DownloadStream, error)

+ func (b *Bucket) OpenDownloadStreamByName(ctx context.Context, name string, opts ...*options.NameOptions) (*DownloadStream, error)

+ func (b *Bucket) OpenUploadStream(ctx context.Context, name string, opts ...*options.UploadOptions) (*UploadStream, error)

+ func (b *Bucket) OpenUploadStreamWithID(ctx context.Context, id interface{}, name string, ...) (*UploadStream, error)

+ func (b *Bucket) Rename(ctx context.Context, id interface{}, name string) error

+ func (b *Bucket) UploadFromStream(ctx context.Context, name string, r io.Reader, opts ...*options.UploadOptions) (primitive.ObjectID, error)

+ func (b *Bucket) UploadFromStreamWithID(ctx context.Context, id interface{}, name string, r io.Reader, ...) error

+ type BucketChunk struct

+ Data []byte

+ File interface{}

+ ID primitive.ObjectID

+ Num int

+ type BucketFile struct

+ ChunkSize int

+ Filename string

+ ID interface{}

+ Length int

+ Metadata interface{}

+ UploadDate time.Time

+ type DownloadStream struct

+ func (s *DownloadStream) Close() error

+ func (s *DownloadStream) Read(buf []uint8) (int, error)

+ func (s *DownloadStream) Seek(offset int64, whence int) (int64, error)

+ func (s *DownloadStream) Skip(skip int64) (int64, error)

+ type UploadStream struct

+ func (s *UploadStream) Abort() error

+ func (s *UploadStream) Close() error

+ func (s *UploadStream) Write(data []uint8) (int, error)

Dec 29, 2019

Changes in this version

+ const Local

type Engine

+ func (e *Engine) Catalog() *Catalog

type Operation

+ Skip int

+ Sort bsonkit.Doc

type Options

+ MaxOplogAge time.Duration

+ MaxOplogSize int

type Transaction

+ func (t *Transaction) Clean(maxSize int, maxAge time.Duration)

Dec 20, 2019

Changes in this version

+ func IsUniquenessError(err error) bool

Dec 20, 2019

Changes in this version

type Client

+ func (c *Client) NumberSessionsInProgress() int

type Cursor

+ func (c *Cursor) TryNext(ctx context.Context) bool

type File

+ func BuildFile(catalog *Catalog) *File

+ func (f *File) BuildCatalog() (*Catalog, error)

type IChangeStream

+ TryNext func(context.Context) bool

type IClient

+ NumberSessionsInProgress func() int

type ICursor

+ TryNext func(context.Context) bool

type Stream

+ func (s *Stream) TryNext(ctx context.Context) bool

Nov 26, 2019

Changes in this version

type FileIndex

+ Expiry time.Duration

Nov 5, 2019

Changes in this version

type Options

+ ExpireErrors func(error)

+ ExpireInterval time.Duration

type Transaction

+ func (t *Transaction) Expire() error

Nov 4, 2019

Changes in this version

+ var ErrEngineClosed = errors.New("engine closed")

+ var ErrSessionEnded = errors.New("session ended")

+ var Oplog = Handle

+ func Open(ctx context.Context, opts Options) (IClient, *Engine, error)

+ func WithSession(ctx context.Context, session ISession, fn func(ISessionContext) error) error

+ type Catalog struct

+ Namespaces map[Handle]*mongokit.Collection

+ func NewCatalog() *Catalog

+ func (d *Catalog) Clone() *Catalog

+ type Client struct

+ func (c *Client) Connect(context.Context) error

+ func (c *Client) Database(name string, opts ...*options.DatabaseOptions) IDatabase

+ func (c *Client) Disconnect(context.Context) error

+ func (c *Client) ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)

+ func (c *Client) ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)

+ func (c *Client) Ping(context.Context, *readpref.ReadPref) error

+ func (c *Client) StartSession(opts ...*options.SessionOptions) (ISession, error)

+ func (c *Client) UseSession(ctx context.Context, fn func(ISessionContext) error) error

+ func (c *Client) UseSessionWithOptions(ctx context.Context, opt *options.SessionOptions, ...) error

+ func (c *Client) Watch(_ context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (IChangeStream, error)

+ type Collection struct

+ func (c *Collection) Aggregate(context.Context, interface{}, ...*options.AggregateOptions) (ICursor, error)

+ func (c *Collection) BulkWrite(ctx context.Context, models []mongo.WriteModel, ...) (*mongo.BulkWriteResult, error)

+ func (c *Collection) Clone(opts ...*options.CollectionOptions) (ICollection, error)

+ func (c *Collection) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

+ func (c *Collection) Database() IDatabase

+ func (c *Collection) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ func (c *Collection) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ func (c *Collection) Distinct(ctx context.Context, field string, filter interface{}, ...) ([]interface{}, error)

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

+ func (c *Collection) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ func (c *Collection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (ICursor, error)

+ func (c *Collection) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) ISingleResult

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

+ func (c *Collection) FindOneAndReplace(ctx context.Context, filter, replacement interface{}, ...) ISingleResult

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

+ func (c *Collection) Indexes() IIndexView

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

+ func (c *Collection) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

+ func (c *Collection) Name() string

+ func (c *Collection) ReplaceOne(ctx context.Context, filter, replacement interface{}, ...) (*mongo.UpdateResult, error)

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

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

+ func (c *Collection) Watch(_ context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (IChangeStream, error)

+ type Cursor struct

+ func (c *Cursor) All(ctx context.Context, out interface{}) error

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

+ func (c *Cursor) Decode(out interface{}) error

+ func (c *Cursor) Err() error

+ func (c *Cursor) ID() int64

+ func (c *Cursor) Next(context.Context) bool

+ type Database struct

+ func (d *Database) Aggregate(context.Context, interface{}, ...*options.AggregateOptions) (ICursor, error)

+ func (d *Database) Client() IClient

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

+ func (d *Database) Drop(ctx context.Context) error

+ func (d *Database) ListCollectionNames(ctx context.Context, filter interface{}, ...) ([]string, error)

+ func (d *Database) ListCollections(ctx context.Context, filter interface{}, ...) (ICursor, error)

+ func (d *Database) Name() string

+ func (d *Database) ReadConcern() *readconcern.ReadConcern

+ func (d *Database) ReadPreference() *readpref.ReadPref

+ func (d *Database) RunCommand(context.Context, interface{}, ...*options.RunCmdOptions) ISingleResult

+ func (d *Database) RunCommandCursor(context.Context, interface{}, ...*options.RunCmdOptions) (ICursor, error)

+ func (d *Database) Watch(_ context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (IChangeStream, error)

+ func (d *Database) WriteConcern() *writeconcern.WriteConcern

+ type Engine struct

+ func CreateEngine(opts Options) (*Engine, error)

+ func (e *Engine) Abort(txn *Transaction)

+ func (e *Engine) Begin(ctx context.Context, lock bool) *Transaction

+ func (e *Engine) Close()

+ func (e *Engine) Commit(txn *Transaction) error

+ func (e *Engine) Watch(handle Handle, filter bsonkit.List, resumeAfter, startAfter bsonkit.Doc, ...) (*Stream, error)

+ type File struct

+ Namespaces map[string]FileNamespace

+ type FileIndex struct

+ Key bsonkit.Doc

+ Partial bsonkit.Doc

+ Unique bool

+ type FileNamespace struct

+ Documents bsonkit.List

+ Indexes map[string]FileIndex

+ type FileStore struct

+ func NewFileStore(path string, mode os.FileMode) *FileStore

+ func (s *FileStore) Load() (*Catalog, error)

+ func (s *FileStore) Store(data *Catalog) error

+ type Handle [2]string

+ func (h Handle) String() string

+ func (h Handle) Validate(needCollection bool) error

+ type IChangeStream interface

+ Close func(context.Context) error

+ Decode func(interface{}) error

+ Err func() error

+ ID func() int64

+ Next func(context.Context) bool

+ ResumeToken func() bson.Raw

+ type IClient interface

+ Connect func(context.Context) error

+ Database func(string, ...*options.DatabaseOptions) IDatabase

+ Disconnect func(context.Context) error

+ ListDatabaseNames func(context.Context, interface{}, ...*options.ListDatabasesOptions) ([]string, error)

+ ListDatabases func(context.Context, interface{}, ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)

+ Ping func(context.Context, *readpref.ReadPref) error

+ StartSession func(...*options.SessionOptions) (ISession, error)

+ UseSession func(context.Context, func(ISessionContext) error) error

+ UseSessionWithOptions func(context.Context, *options.SessionOptions, func(ISessionContext) error) error

+ Watch func(context.Context, interface{}, ...*options.ChangeStreamOptions) (IChangeStream, error)

+ func Connect(ctx context.Context, opts ...*options.ClientOptions) (IClient, error)

+ func NewClient(engine *Engine) IClient

+ type ICollection interface

+ Aggregate func(context.Context, interface{}, ...*options.AggregateOptions) (ICursor, error)

+ BulkWrite func(context.Context, []mongo.WriteModel, ...*options.BulkWriteOptions) (*mongo.BulkWriteResult, error)

+ Clone func(...*options.CollectionOptions) (ICollection, error)

+ CountDocuments func(context.Context, interface{}, ...*options.CountOptions) (int64, error)

+ Database func() IDatabase

+ DeleteMany func(context.Context, interface{}, ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ DeleteOne func(context.Context, interface{}, ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ Distinct func(context.Context, string, interface{}, ...*options.DistinctOptions) ([]interface{}, error)

+ Drop func(context.Context) error

+ EstimatedDocumentCount func(context.Context, ...*options.EstimatedDocumentCountOptions) (int64, error)

+ Find func(context.Context, interface{}, ...*options.FindOptions) (ICursor, error)

+ FindOne func(context.Context, interface{}, ...*options.FindOneOptions) ISingleResult

+ FindOneAndDelete func(context.Context, interface{}, ...*options.FindOneAndDeleteOptions) ISingleResult

+ FindOneAndReplace func(context.Context, interface{}, interface{}, ...) ISingleResult

+ FindOneAndUpdate func(context.Context, interface{}, interface{}, ...*options.FindOneAndUpdateOptions) ISingleResult

+ Indexes func() IIndexView

+ InsertMany func(context.Context, []interface{}, ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)

+ InsertOne func(context.Context, interface{}, ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

+ Name func() string

+ ReplaceOne func(context.Context, interface{}, interface{}, ...*options.ReplaceOptions) (*mongo.UpdateResult, error)

+ UpdateMany func(context.Context, interface{}, interface{}, ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ UpdateOne func(context.Context, interface{}, interface{}, ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ Watch func(context.Context, interface{}, ...*options.ChangeStreamOptions) (IChangeStream, error)

+ type ICursor interface

+ All func(context.Context, interface{}) error

+ Close func(context.Context) error

+ Decode func(interface{}) error

+ Err func() error

+ ID func() int64

+ Next func(context.Context) bool

+ type IDatabase interface

+ Aggregate func(context.Context, interface{}, ...*options.AggregateOptions) (ICursor, error)

+ Client func() IClient

+ Collection func(string, ...*options.CollectionOptions) ICollection

+ Drop func(context.Context) error

+ ListCollectionNames func(context.Context, interface{}, ...*options.ListCollectionsOptions) ([]string, error)

+ ListCollections func(context.Context, interface{}, ...*options.ListCollectionsOptions) (ICursor, error)

+ Name func() string

+ ReadConcern func() *readconcern.ReadConcern

+ ReadPreference func() *readpref.ReadPref

+ RunCommand func(context.Context, interface{}, ...*options.RunCmdOptions) ISingleResult

+ RunCommandCursor func(context.Context, interface{}, ...*options.RunCmdOptions) (ICursor, error)

+ Watch func(context.Context, interface{}, ...*options.ChangeStreamOptions) (IChangeStream, error)

+ WriteConcern func() *writeconcern.WriteConcern

+ type IIndexView interface

+ CreateMany func(context.Context, []mongo.IndexModel, ...*options.CreateIndexesOptions) ([]string, error)

+ CreateOne func(context.Context, mongo.IndexModel, ...*options.CreateIndexesOptions) (string, error)

+ DropAll func(context.Context, ...*options.DropIndexesOptions) (bson.Raw, error)

+ DropOne func(context.Context, string, ...*options.DropIndexesOptions) (bson.Raw, error)

+ List func(context.Context, ...*options.ListIndexesOptions) (ICursor, error)

+ type ISession interface

+ AbortTransaction func(context.Context) error

+ AdvanceClusterTime func(bson.Raw) error

+ AdvanceOperationTime func(*primitive.Timestamp) error

+ Client func() IClient

+ ClusterTime func() bson.Raw

+ CommitTransaction func(context.Context) error

+ EndSession func(context.Context)

+ OperationTime func() *primitive.Timestamp

+ StartTransaction func(...*options.TransactionOptions) error

+ WithTransaction func(ctx context.Context, fn func(sessCtx ISessionContext) (interface{}, error), ...) (interface{}, error)

+ type ISessionContext interface

+ type ISingleResult interface

+ Decode func(interface{}) error

+ DecodeBytes func() (bson.Raw, error)

+ Err func() error

+ type IndexView struct

+ func (v *IndexView) CreateMany(ctx context.Context, indexes []mongo.IndexModel, ...) ([]string, error)

+ func (v *IndexView) CreateOne(ctx context.Context, index mongo.IndexModel, ...) (string, error)

+ func (v *IndexView) DropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (bson.Raw, error)

+ func (v *IndexView) DropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (bson.Raw, error)

+ func (v *IndexView) List(ctx context.Context, opts ...*options.ListIndexesOptions) (ICursor, error)

+ type MemoryStore struct

+ func NewMemoryStore() *MemoryStore

+ func (m MemoryStore) Load() (*Catalog, error)

+ func (m MemoryStore) Store(data *Catalog) error

+ type MongoClient struct

+ func (c *MongoClient) Database(name string, opts ...*options.DatabaseOptions) IDatabase

+ func (c *MongoClient) StartSession(opts ...*options.SessionOptions) (ISession, error)

+ func (c *MongoClient) UseSession(ctx context.Context, fn func(ISessionContext) error) error

+ func (c *MongoClient) UseSessionWithOptions(ctx context.Context, opt *options.SessionOptions, ...) error

+ func (c *MongoClient) Watch(ctx context.Context, pipeline interface{}, ...) (IChangeStream, error)

+ type MongoCollection struct

+ func (c *MongoCollection) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (ICursor, error)

+ func (c *MongoCollection) Clone(opts ...*options.CollectionOptions) (ICollection, error)

+ func (c *MongoCollection) Database() IDatabase

+ func (c *MongoCollection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (ICursor, error)

+ func (c *MongoCollection) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) ISingleResult

+ func (c *MongoCollection) FindOneAndDelete(ctx context.Context, filter interface{}, ...) ISingleResult

+ func (c *MongoCollection) FindOneAndReplace(ctx context.Context, filter, replacement interface{}, ...) ISingleResult

+ func (c *MongoCollection) FindOneAndUpdate(ctx context.Context, filter, update interface{}, ...) ISingleResult

+ func (c *MongoCollection) Indexes() IIndexView

+ func (c *MongoCollection) Watch(ctx context.Context, pipeline interface{}, ...) (IChangeStream, error)

+ type MongoDatabase struct

+ func (d *MongoDatabase) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (ICursor, error)

+ func (d *MongoDatabase) Client() IClient

+ func (d *MongoDatabase) Collection(name string, opts ...*options.CollectionOptions) ICollection

+ func (d *MongoDatabase) ListCollections(ctx context.Context, filter interface{}, ...) (ICursor, error)

+ func (d *MongoDatabase) RunCommand(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) ISingleResult

+ func (d *MongoDatabase) RunCommandCursor(ctx context.Context, filter interface{}, opts ...*options.RunCmdOptions) (ICursor, error)

+ func (d *MongoDatabase) Watch(ctx context.Context, pipeline interface{}, ...) (IChangeStream, error)

+ type MongoIndexView struct

+ func (m *MongoIndexView) List(ctx context.Context, opts ...*options.ListIndexesOptions) (ICursor, error)

+ type MongoSession struct

+ func (s *MongoSession) Client() IClient

+ func (s *MongoSession) WithTransaction(ctx context.Context, fn func(ISessionContext) (interface{}, error), ...) (interface{}, error)

+ type MongoSessionContext struct

+ type Opcode int

+ const Delete

+ const Insert

+ const Replace

+ const Update

+ func (c Opcode) String() string

+ type Operation struct

+ Document bsonkit.Doc

+ Filter bsonkit.Doc

+ Limit int

+ Opcode Opcode

+ Upsert bool

+ type Options struct

+ Store Store

+ type Result struct

+ Error error

+ Matched bsonkit.List

+ Modified bsonkit.List

+ Upserted bsonkit.Doc

+ type Session struct

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

+ func (s *Session) AdvanceClusterTime(bson.Raw) error

+ func (s *Session) AdvanceOperationTime(*primitive.Timestamp) error

+ func (s *Session) Client() IClient

+ func (s *Session) ClusterTime() bson.Raw

+ func (s *Session) CommitTransaction(context.Context) error

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

+ func (s *Session) OperationTime() *primitive.Timestamp

+ func (s *Session) StartTransaction(opts ...*options.TransactionOptions) error

+ func (s *Session) Transaction() *Transaction

+ func (s *Session) WithTransaction(ctx context.Context, fn func(ISessionContext) (interface{}, error), ...) (interface{}, error)

+ type SessionContext struct

+ type SingleResult struct

+ func (r *SingleResult) Decode(out interface{}) error

+ func (r *SingleResult) DecodeBytes() (bson.Raw, error)

+ func (r *SingleResult) Err() error

+ type Store interface

+ Load func() (*Catalog, error)

+ Store func(*Catalog) error

+ type Stream struct

+ func (s *Stream) Close(context.Context) error

+ func (s *Stream) Decode(out interface{}) error

+ func (s *Stream) Err() error

+ func (s *Stream) ID() int64

+ func (s *Stream) Next(ctx context.Context) bool

+ func (s *Stream) ResumeToken() bson.Raw

+ type Transaction struct

+ func NewTransaction(catalog *Catalog) *Transaction

+ func (t *Transaction) Bulk(handle Handle, ops []Operation, ordered bool) ([]Result, error)

+ func (t *Transaction) Catalog() *Catalog

+ func (t *Transaction) CountDocuments(handle Handle) (int, error)

+ func (t *Transaction) CreateIndex(handle Handle, key bsonkit.Doc, name string, unique bool, partial bsonkit.Doc) (string, error)

+ func (t *Transaction) Delete(handle Handle, query, sort bsonkit.Doc, limit int) (*Result, error)

+ func (t *Transaction) Dirty() bool

+ func (t *Transaction) Drop(handle Handle) error

+ func (t *Transaction) DropIndex(handle Handle, name string) error

+ func (t *Transaction) Find(handle Handle, query, sort bsonkit.Doc, skip, limit int) (*Result, error)

+ func (t *Transaction) Insert(handle Handle, list bsonkit.List, ordered bool) (*Result, error)

+ func (t *Transaction) ListCollections(handle Handle, query bsonkit.Doc) (bsonkit.List, error)

+ func (t *Transaction) ListDatabases(query bsonkit.Doc) (bsonkit.List, error)

+ func (t *Transaction) ListIndexes(handle Handle) (bsonkit.List, error)

+ func (t *Transaction) Replace(handle Handle, query, sort, repl bsonkit.Doc, upsert bool) (*Result, error)

+ func (t *Transaction) Update(handle Handle, query, sort, update bsonkit.Doc, limit int, upsert bool) (*Result, error)