mongo_util

Documentation

Index

• func InsertedIDToObjectId(insertedID interface{}) primitive.ObjectID
• func WithSession(database *mongo.Database, ctx context.Context, ...) error
• func WithTransaction(database *mongo.Database, ctx context.Context, ...) error
• type DocumentKey
• type MongoUpdateStatement
• type WatchChangeEvent

Functions

func InsertedIDToObjectId

func InsertedIDToObjectId(insertedID interface{}) primitive.ObjectID

func WithSession

func WithSession(database *mongo.Database, ctx context.Context, fn func(sc mongo.SessionContext) error) error

func WithTransaction

func WithTransaction(database *mongo.Database, ctx context.Context, fn func(sc mongo.SessionContext) error) error

Types

type DocumentKey

type DocumentKey struct {
	Id primitive.ObjectID `bson:"_id"`
}

type MongoUpdateStatement

type MongoUpdateStatement struct {
	Set         bsoncore.Document `bson:"$set,omitempty"`
	SetOnInsert bsoncore.Document `bson:"$setOnInsert,omitempty"`
}

type WatchChangeEvent

type WatchChangeEvent[D any] struct {
	OperationType string      `bson:"operationType"`
	FullDocument  D           `bson:"fullDocument,omitempty"`
	DocumentKey   DocumentKey `bson:"documentKey"`
}