dbm

package module

Go to main page

Versions in this module

v0

v0.0.14

May 1, 2024

Changes in this version

type Client

+ BeginTx func(ctx context.Context, opts ...*TransactionOptions) (Tx, error)

type Database

+ BeginTx func(ctx context.Context, opts ...*TransactionOptions) (Tx, error)

type Session

+ BeginTx func(ctx context.Context, opts ...*TransactionOptions) (Tx, error)

v0.0.13

May 1, 2024

v0.0.12

Apr 30, 2024

Changes in this version

+ const Off

+ const Required

+ const WhenAvailable

type ChangeEvent

+ DocumentKey DocumentKey

+ WallTime DateTime

+ type ChangeStream = mongo.ChangeStream

+ type ChangeStreamOptions = options.ChangeStreamOptions

+ func NewChangeStreamOptions() *ChangeStreamOptions

type Client

+ Begin func(ctx context.Context, opts ...*TransactionOptions) (Tx, error)

type Database

+ Begin func(ctx context.Context, opts ...*TransactionOptions) (Tx, error)

+ type DocumentKey struct

+ Id string

type Session

+ Begin func(ctx context.Context, opts ...*TransactionOptions) (Tx, error)

+ type Tx interface

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

v0.0.11

Jan 24, 2024

v0.0.10

Jan 7, 2024

Changes in this version

+ const After

+ const Before

+ const Default

+ const NonTailable

+ const OperationTypeDelete

+ const OperationTypeInsert

+ const OperationTypeInvalidate

+ const OperationTypeReplace

+ const OperationTypeUpdate

+ const Tailable

+ const TailableAwait

+ const UpdateLookup

+ var ErrNoDocuments = mongo.ErrNoDocuments

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

+ var ErrSessionNotSupported = errors.New("session not supported")

+ func CompareServerVersions(v1 string, v2 string) int

+ func IsValidObjectId(s string) bool

+ type A = bson.A

+ func NA(items ...interface{}) A

+ type Aggregate interface

+ All func(result interface{}) error

+ AllowDiskUse func(b bool) Aggregate

+ BatchSize func(n int32) Aggregate

+ BypassDocumentValidation func(b bool) Aggregate

+ Collation func(c *Collation) Aggregate

+ Comment func(s string) Aggregate

+ Cursor func() Cursor

+ Hint func(hint interface{}) Aggregate

+ MaxAwaitTime func(d time.Duration) Aggregate

+ MaxTime func(d time.Duration) Aggregate

+ One func(result interface{}) error

+ type ArrayFilters = options.ArrayFilters

+ type Bulk interface

+ AddModel func(m WriteModel) Bulk

+ Apply func() (*BulkResult, error)

+ BypassDocumentValidation func(bypass bool) Bulk

+ DeleteId func(id interface{}) Bulk

+ DeleteMany func(filter interface{}) Bulk

+ DeleteOne func(filter interface{}) Bulk

+ InsertOne func(document interface{}) Bulk

+ InsertOneNx func(filter interface{}, document interface{}) Bulk

+ Ordered func(ordered bool) Bulk

+ ReplaceOne func(filter interface{}, replacement interface{}) Bulk

+ RepsertOne func(filter interface{}, replacement interface{}) Bulk

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

+ UpdateMany func(filter interface{}, update interface{}) Bulk

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

+ Upsert func(filter interface{}, update interface{}) Bulk

+ UpsertId func(id interface{}, update interface{}) Bulk

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

+ type BulkResult = mongo.BulkWriteResult

+ type ChangeEvent struct

+ ClusterTime Timestamp

+ Id EventId

+ Namespace Namespace

+ OperationType OperationType

+ type Client interface

+ Client func() *mongo.Client

+ Close func(ctx context.Context) error

+ Database func(name string, opts ...*DatabaseOptions) Database

+ Ping func(ctx context.Context) error

+ Registry func() *bsoncodec.Registry

+ ServerStatus func(ctx context.Context) (bson.Raw, error)

+ ServerVersion func() string

+ StartSession func(ctx context.Context, opts ...*SessionOptions) (Session, error)

+ TransactionAllowed func() bool

+ UseSession func(ctx context.Context, fn func(sess Session) error) error

+ UseSessionWithOptions func(ctx context.Context, opts *SessionOptions, fn func(sess Session) error) error

+ Watch func(ctx context.Context, pipeline interface{}) Watcher

+ WithTransaction func(ctx context.Context, fn func(sCtx SessionContext) (interface{}, error), ...) (interface{}, error)

+ func New(ctx context.Context, cfg *Config) (Client, error)

+ type Collation = options.Collation

+ type Collection interface

+ Aggregate func(ctx context.Context, pipeline interface{}) Aggregate

+ Bulk func(ctx context.Context) Bulk

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

+ Collection func() *mongo.Collection

+ Database func() Database

+ DeleteId func(ctx context.Context, id interface{}, opts ...*DeleteOptions) (*DeleteResult, error)

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

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

+ Distinct func(ctx context.Context, fieldName string, filter interface{}) Distinct

+ Drop func(ctx context.Context) error

+ Find func(ctx context.Context, filter interface{}) Query

+ FindOneAndDelete func(ctx context.Context, filter interface{}) FindDelete

+ FindOneAndReplace func(ctx context.Context, filter interface{}, replacement interface{}) FindReplace

+ FindOneAndUpdate func(ctx context.Context, filter interface{}, update interface{}) FindUpdate

+ IndexView func() IndexView

+ Insert func(ctx context.Context, documents ...interface{}) (*InsertManyResult, error)

+ InsertMany func(ctx context.Context, documents []interface{}, opts ...*InsertManyOptions) (*InsertManyResult, error)

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

+ InsertOneNx func(ctx context.Context, filter interface{}, document interface{}, ...) (*UpdateResult, error)

+ Name func() string

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

+ RepsertOne func(ctx context.Context, filter interface{}, replacement interface{}, ...) (*UpdateResult, error)

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

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

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

+ Upsert func(ctx context.Context, filter interface{}, update interface{}, ...) (*UpdateResult, error)

+ UpsertId func(ctx context.Context, id interface{}, update interface{}, ...) (*UpdateResult, error)

+ UpsertOne func(ctx context.Context, filter interface{}, update interface{}, ...) (*UpdateResult, error)

+ Watch func(ctx context.Context, pipeline interface{}) Watcher

+ type CollectionOptions = options.CollectionOptions

+ func NewCollectionOptions() *CollectionOptions

+ type Config struct

+ func NewConfig(uri string) *Config

+ type Cursor interface

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

+ Close func(ctx context.Context) error

+ Error func() error

+ ID func() int64

+ Next func(ctx context.Context) bool

+ One func(result interface{}) error

+ RemainingBatchLength func() int

+ TryNext func(ctx context.Context) bool

+ type CursorType = options.CursorType

+ type D = bson.D

+ func ND(items ...E) D

+ type Database interface

+ Client func() Client

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

+ Database func() *mongo.Database

+ Drop func(ctx context.Context) error

+ Name func() string

+ StartSession func(ctx context.Context, opts ...*SessionOptions) (Session, error)

+ UseSession func(ctx context.Context, fn func(sess Session) error) error

+ UseSessionWithOptions func(ctx context.Context, opts *SessionOptions, fn func(sess Session) error) error

+ Watch func(ctx context.Context, pipeline interface{}) Watcher

+ WithTransaction func(ctx context.Context, fn func(sCtx SessionContext) (interface{}, error), ...) (interface{}, error)

+ type DatabaseOptions = options.DatabaseOptions

+ func NewDatabaseOptions() *DatabaseOptions

+ type DateTime = primitive.DateTime

+ type Decimal128 = primitive.Decimal128

+ func NewDecimal128(h, l uint64) Decimal128

+ type DeleteManyModel = mongo.DeleteManyModel

+ func NewDeleteManyModel() *DeleteManyModel

+ type DeleteOneModel = mongo.DeleteOneModel

+ func NewDeleteOneModel() *DeleteOneModel

+ type DeleteOptions = options.DeleteOptions

+ func NewDeleteOptions() *DeleteOptions

+ type DeleteResult = mongo.DeleteResult

+ type Distinct interface

+ Apply func(result interface{}) error

+ Collation func(c *Collation) Distinct

+ MaxTime func(d time.Duration) Distinct

+ type E = bson.E

+ func NE(key string, value interface{}) E

+ type EventId struct

+ Data string

+ type FindDelete interface

+ Apply func(result interface{}) error

+ Collation func(c *Collation) FindDelete

+ Hint func(hint interface{}) FindDelete

+ MaxTime func(d time.Duration) FindDelete

+ Project func(projection interface{}) FindDelete

+ Sort func(fields ...string) FindDelete

+ type FindReplace interface

+ Apply func(result interface{}) error

+ BypassDocumentValidation func(b bool) FindReplace

+ Collation func(c *Collation) FindReplace

+ Hint func(hint interface{}) FindReplace

+ MaxTime func(d time.Duration) FindReplace

+ Project func(projection interface{}) FindReplace

+ ReturnDocument func(rd ReturnDocument) FindReplace

+ Sort func(fields ...string) FindReplace

+ Upsert func(b bool) FindReplace

+ type FindUpdate interface

+ Apply func(result interface{}) error

+ ArrayFilters func(filters ArrayFilters) FindUpdate

+ BypassDocumentValidation func(b bool) FindUpdate

+ Collation func(c *Collation) FindUpdate

+ Hint func(hint interface{}) FindUpdate

+ MaxTime func(d time.Duration) FindUpdate

+ Project func(projection interface{}) FindUpdate

+ ReturnDocument func(rd ReturnDocument) FindUpdate

+ Sort func(fields ...string) FindUpdate

+ Upsert func(b bool) FindUpdate

+ type FullDocument = options.FullDocument

+ type IndexOptions = options.IndexOptions

+ func NewIndexOptions() *IndexOptions

+ type IndexView interface

+ Create func(ctx context.Context, keys []string, opts *IndexOptions) (string, error)

+ CreateIndex func(ctx context.Context, name string, keys []string) (string, error)

+ CreateTTLIndex func(ctx context.Context, name string, keys []string, ttl int32) (string, error)

+ CreateUniqueIndex func(ctx context.Context, name string, keys []string) (string, error)

+ Drop func(ctx context.Context, name string) error

+ DropAll func(ctx context.Context) error

+ DropIndex func(ctx context.Context, keys []string) error

+ IndexView func() mongo.IndexView

+ type InsertManyOptions = options.InsertManyOptions

+ func NewInsertManyOptions() *InsertManyOptions

+ type InsertManyResult = mongo.InsertManyResult

+ type InsertOneModel = mongo.InsertOneModel

+ func NewInsertOneModel() *InsertOneModel

+ type InsertOneOptions = options.InsertOneOptions

+ func NewInsertOneOptions() *InsertOneOptions

+ type InsertOneResult = mongo.InsertOneResult

+ type M = bson.M

+ type Namespace struct

+ Collection string

+ Database string

+ type Null = primitive.Null

+ type ObjectId = primitive.ObjectID

+ func MustObjectId(s string) ObjectId

+ func NewObjectId() ObjectId

+ func NewObjectIdFromTime(t time.Time) ObjectId

+ func ObjectIdFromHex(s string) (ObjectId, error)

+ type OperationType string

+ type Pipeline = mongo.Pipeline

+ func NP(items ...D) Pipeline

+ type Query interface

+ All func(result interface{}) error

+ AllowDiskUse func(b bool) Query

+ AllowPartialResults func(b bool) Query

+ BatchSize func(n int32) Query

+ Collation func(c *Collation) Query

+ Comment func(s string) Query

+ Count func() (int64, error)

+ Cursor func() Cursor

+ CursorType func(cursorType CursorType) Query

+ Hint func(hint interface{}) Query

+ Limit func(n int64) Query

+ Max func(m interface{}) Query

+ MaxAwaitTime func(d time.Duration) Query

+ MaxTime func(d time.Duration) Query

+ Min func(m interface{}) Query

+ NoCursorTimeout func(b bool) Query

+ One func(result interface{}) error

+ Project func(projection interface{}) Query

+ ReturnKey func(b bool) Query

+ Select func(projection interface{}) Query

+ ShowRecordId func(b bool) Query

+ Skip func(n int64) Query

+ Sort func(fields ...string) Query

+ type Raw = bson.Raw

+ type Regex = primitive.Regex

+ func NR(pattern, options string) Regex

+ type ReplaceOneModel = mongo.ReplaceOneModel

+ func NewReplaceOneModel() *ReplaceOneModel

+ type ReplaceOptions = options.ReplaceOptions

+ func NewReplaceOptions() *ReplaceOptions

+ type ReturnDocument = options.ReturnDocument

+ type Session interface

+ Context func() SessionContext

+ EndSession func(context.Context)

+ StartTransaction func(...*TransactionOptions) error

+ WithTransaction func(context.Context, func(sCtx SessionContext) (interface{}, error), ...) (interface{}, error)

+ type SessionContext interface

+ AbortTransaction func(context.Context) error

+ CommitTransaction func(context.Context) error

+ type SessionOptions = options.SessionOptions

+ func NewSessionOptions() *SessionOptions

+ type Stream interface

+ Close func(ctx context.Context) error

+ Error func() error

+ ID func() int64

+ Next func(ctx context.Context) bool

+ One func(result interface{}) error

+ ResumeToken func() Raw

+ TryNext func(ctx context.Context) bool

+ type Timestamp = primitive.Timestamp

+ type TransactionOptions = options.TransactionOptions

+ func NewTransactionOptions() *TransactionOptions

+ type UpdateManyModel = mongo.UpdateManyModel

+ func NewUpdateManyModel() *UpdateManyModel

+ type UpdateOneModel = mongo.UpdateOneModel

+ func NewUpdateOneModel() *UpdateOneModel

+ type UpdateOptions = options.UpdateOptions

+ func NewUpdateOptions() *UpdateOptions

+ type UpdateResult = mongo.UpdateResult

+ type Watcher interface

+ BatchSize func(n int32) Watcher

+ Collation func(c Collation) Watcher

+ FullDocument func(fd FullDocument) Watcher

+ MaxAwaitTime func(d time.Duration) Watcher

+ ResumeAfter func(rt interface{}) Watcher

+ StartAfter func(sa interface{}) Watcher

+ StartAtOperationTime func(t *Timestamp) Watcher

+ Stream func() Stream

+ type WriteModel = mongo.WriteModel

v0.0.9

Oct 12, 2021

v0.0.8

Oct 12, 2021

v0.0.7

Sep 2, 2021

v0.0.6

Sep 2, 2021

v0.0.5

May 20, 2021

v0.0.4

May 12, 2021

v0.0.3

May 6, 2021

v0.0.2

Apr 28, 2021

v0.0.1

Apr 27, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL