mongo

package

Go to main page

Versions in this module

v1

v1.2.2

Mar 4, 2024

v1.2.1

Feb 18, 2024

Changes in this version

type Template

+ func (t *Template) FindOneAndDeleteById(ctx context.Context, id, dest any, opts ...*option.FindOneAndDelete) error

+ func (t *Template) FindOneAndReplaceById(ctx context.Context, id, replacement, dest any, ...) error

+ func (t *Template) FindOneAndUpdateById(ctx context.Context, id, update, dest any, opts ...*option.FindOneAndUpdate) error

+ func (t *Template) SetGlobalOption(opt *option.Global)

v1.2.0

Feb 5, 2024

v1.1.9

Jan 30, 2024

v1.1.8

Jan 30, 2024

Changes in this version

type PageResult

+ func (p PageResult) Decode(dest any) error

v1.1.7

Jan 30, 2024

v1.1.6

Jan 30, 2024

Changes in this version

type FullDocument

+ func (f FullDocument) Decode(dest any) error

v1.1.5

Jan 30, 2024

v1.1.4

Jan 28, 2024

v1.1.3

Jan 28, 2024

v1.1.2

Jan 25, 2024

Changes in this version

+ var MsgErrCollectionNotConfigured = "mongo: collection not correct configured"

+ var MsgErrDatabaseNotConfigured = "mongo: database not correct configured"

+ var MsgErrDestIsNotPointer = "mongo: dest param is not a pointer"

+ var MsgErrDestIsNotStruct = "mongo: dest param is not a struct"

+ var MsgErrDocumentIsEmpty = "mongo: document param is empty"

+ var MsgErrDocumentIsNotPointer = "mongo: document param is not a pointer"

+ var MsgErrDocumentIsNotStruct = "mongo: document param is not a struct"

+ var MsgErrDocumentsIsEmpty = "mongo: documents param is empty"

+ var MsgErrNoDocuments = "mongo: no documents in result"

+ var MsgErrNoOpenSession = "mongo: no open session"

+ var MsgErrRefDocument = "mongo: ref document needs to be structure or slice of the struct"

+ type Event struct

+ ClusterTime primitive.Timestamp

+ DocumentKey documentKey

+ FullDocument FullDocument

+ NS ns

+ OperationType string

+ UpdateDescription updateDescription

+ type FullDocument bson.M

+ func (f FullDocument) ParseToStruct(dest any) error

v1.1.1

Jan 18, 2024

v1.1.0

Jan 18, 2024

v1.0.9

Jan 18, 2024

Changes in this version

+ type EventContext struct

+ Event EventInfo

+ type EventHandler func(ctx *EventContext)

+ type EventInfo struct

+ ClusterTime primitive.Timestamp

+ DocumentKey documentKey

+ FullDocument bson.M

+ NS ns

+ OperationType string

+ UpdateDescription updateDescription

v1.0.8

Jan 18, 2024

Changes in this version

+ type Handler func(ctx *ContextWatch)

type Template

+ func (t *Template) WatchWithHandler(ctx context.Context, pipeline any, handler Handler, ...) error

v1.0.7

Jan 17, 2024

Changes in this version

type Template

+ func (t *Template) GetClient() mongo.Client

v1.0.6

Jan 17, 2024

v1.0.5

Jan 16, 2024

v1.0.4

Jan 15, 2024

Changes in this version

type Template

+ func (t *Template) SimpleDisconnect(ctx context.Context)

v1.0.3

Jan 14, 2024

Changes in this version

+ var ErrNoOpenSession = errors.New("mongo: no open session")

type Template

+ func (t *Template) StartSession(ctx context.Context) error

v1.0.2

Jan 12, 2024

Changes in this version

+ type DeleteResult struct

+ DeletedCount int64

+ type IndexResult struct

+ FirstBatch FirstBatchIndex

+ Id any

+ Ns string

+ type IndexSpecification struct

+ Clustered *bool

+ ExpireAfterSeconds *int32

+ KeysDocument bson.Raw

+ Name string

+ Namespace string

+ Sparse *bool

+ Unique *bool

+ Version int32

+ type PageResult struct

+ Content any

+ LastQueryAt time.Time

+ Page int64

+ PageSize int64

+ PageTotal int64

+ TotalElements int64

+ type UpdateResult struct

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedCount int64

+ UpsertedID any

v1.0.1

Jan 4, 2024

Changes in this version

+ var ErrCollectionNotConfigured = errors.New("mongo: collection not correct configured")

+ var ErrDatabaseNotConfigured = errors.New("mongo: database not correct configured")

+ var ErrDestIsNotPointer = errors.New("mongo: dest param is not a pointer")

+ var ErrDestIsNotStruct = errors.New("mongo: dest param is not a struct")

+ var ErrDocumentIsEmpty = errors.New("mongo: document param is empty")

+ var ErrDocumentIsNotPointer = errors.New("mongo: document param is not a pointer")

+ var ErrDocumentIsNotStruct = errors.New("mongo: document param is not a struct")

+ var ErrDocumentsIsEmpty = errors.New("mongo: documents param is empty")

+ var ErrNoDocuments = errors.New("mongo: no documents in result")

+ var ErrRefDocument = errors.New("mongo: ref document needs to be structure or slice of the struct")

+ var ErrWatchHandlerIsNil = errors.New("mongo: watch handler is nil")

+ type ContextWatch struct

+ Event WatchEvent

+ type FirstBatchIndex struct

+ Key primitive.M

+ Name string

+ Ns string

+ V int

+ type HandlerWatch func(ctx *ContextWatch)

+ type IndexInput struct

+ Keys any

+ Options option.Index

+ Ref any

+ type IndexOutput struct

+ FirstBatch FirstBatchIndex

+ Id any

+ Ns string

+ type PageInput struct

+ Page int64

+ PageSize int64

+ Ref any

+ Sort any

+ type PageOutput struct

+ Content any

+ LastQueryAt time.Time

+ Page int64

+ PageSize int64

+ PageTotal int64

+ TotalElements int64

+ func NewPageOutput(pageInput PageInput, result any, countTotal int64) *PageOutput

+ type Pipeline []bson.D

+ type Sort int

+ const SortAsc

+ const SortDesc

+ type Template interface

+ AbortTransaction func(ctx context.Context) error

+ Aggregate func(ctx context.Context, pipeline, dest any, opts ...option.Aggregate) error

+ CloseSession func(ctx context.Context, abort bool) error

+ CommitTransaction func(ctx context.Context) error

+ CountDocuments func(ctx context.Context, filter, ref any, opts ...option.Count) (int64, error)

+ CreateManyIndex func(ctx context.Context, inputs []IndexInput) ([]string, error)

+ CreateOneIndex func(ctx context.Context, input IndexInput) (string, error)

+ DeleteMany func(ctx context.Context, filter, ref any, opts ...option.Delete) (*mongo.DeleteResult, error)

+ DeleteOne func(ctx context.Context, filter, ref any, opts ...option.Delete) (*mongo.DeleteResult, error)

+ DeleteOneById func(ctx context.Context, id, ref any, opts ...option.Delete) (*mongo.DeleteResult, error)

+ Disconnect func(ctx context.Context)

+ DisconnectWithErr func(ctx context.Context) error

+ Distinct func(ctx context.Context, fieldName string, filter, dest, ref any, ...) error

+ DropAllIndexes func(ctx context.Context, ref any, opts ...option.DropIndex) error

+ DropCollection func(ctx context.Context, ref any) error

+ DropDatabase func(ctx context.Context, ref any) error

+ DropOneIndex func(ctx context.Context, name string, ref any, opts ...option.DropIndex) error

+ EstimatedDocumentCount func(ctx context.Context, ref any, opts ...option.EstimatedDocumentCount) (int64, error)

+ Exists func(ctx context.Context, filter, ref any, opts ...option.Exists) (bool, error)

+ ExistsById func(ctx context.Context, id, ref any, opts ...option.Exists) (bool, error)

+ Find func(ctx context.Context, filter, dest any, opts ...option.Find) error

+ FindAll func(ctx context.Context, dest any, opts ...option.Find) error

+ FindOne func(ctx context.Context, filter, dest any, opts ...option.FindOne) error

+ FindOneAndDelete func(ctx context.Context, filter, dest any, opts ...option.FindOneAndDelete) error

+ FindOneAndReplace func(ctx context.Context, filter, replacement, dest any, ...) error

+ FindOneAndUpdate func(ctx context.Context, filter, update, dest any, opts ...option.FindOneAndUpdate) error

+ FindOneById func(ctx context.Context, id, dest any, opts ...option.FindOneById) error

+ FindPageable func(ctx context.Context, filter any, input PageInput, opts ...option.FindPageable) (*PageOutput, error)

+ InsertMany func(ctx context.Context, documents any, opts ...option.InsertMany) error

+ InsertOne func(ctx context.Context, document any, opts ...option.InsertOne) error

+ ListIndexSpecifications func(ctx context.Context, ref any, opts ...option.ListIndexes) ([]*mongo.IndexSpecification, error)

+ ListIndexes func(ctx context.Context, ref any, opts ...option.ListIndexes) ([]IndexOutput, error)

+ ReplaceOne func(ctx context.Context, filter, replacement, ref any, opts ...option.Replace) (*mongo.UpdateResult, error)

+ ReplaceOneById func(ctx context.Context, id, replacement, ref any, opts ...option.Replace) (*mongo.UpdateResult, error)

+ UpdateMany func(ctx context.Context, filter, update, ref any, opts ...option.Update) (*mongo.UpdateResult, error)

+ UpdateOne func(ctx context.Context, filter, update, ref any, opts ...option.Update) (*mongo.UpdateResult, error)

+ UpdateOneById func(ctx context.Context, id, update, ref any, opts ...option.Update) (*mongo.UpdateResult, error)

+ Watch func(ctx context.Context, pipeline any, opts ...option.Watch) (*mongo.ChangeStream, error)

+ WatchHandler func(ctx context.Context, pipeline any, handler HandlerWatch, ...) error

+ func NewTemplate(ctx context.Context, opts ...*options.ClientOptions) (Template, error)

+ type WatchEvent struct

+ ClusterTime primitive.Timestamp

+ DocumentKey documentKey

+ FullDocument bson.M

+ NS ns

+ OperationType string

+ UpdateDescription updateDescription

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