database

Documentation

Index

• Variables
• type MongoFactory
  • func NewMongoFactory(client *mongo.Client, config MongoFactoryConfig) *MongoFactory
  • func (mf *MongoFactory) NewDeltaCollection() *mongo.Collection
  • func (mf *MongoFactory) NewSnapshotCollection() *mongo.Collection
  • func (mf *MongoFactory) NewUserCollection() *mongo.Collection
• type MongoFactoryConfig
• type TransactionManager
  • func NewTransactionManager(client *mongo.Client, transactionsEnabled bool) *TransactionManager
  • func (tm *TransactionManager) IsInTransaction(ctx context.Context) bool
  • func (tm *TransactionManager) WithTransaction(ctx context.Context, fn func(ctx context.Context) error) error

Variables

var ErrGeneric = errors.New("generic database error")

var ErrNotFound = errors.New("not found")

Types

type MongoFactory

type MongoFactory struct {
	// contains filtered or unexported fields
}

func NewMongoFactory

func NewMongoFactory(client *mongo.Client, config MongoFactoryConfig) *MongoFactory

func (*MongoFactory) NewDeltaCollection

func (mf *MongoFactory) NewDeltaCollection() *mongo.Collection

func (*MongoFactory) NewSnapshotCollection

func (mf *MongoFactory) NewSnapshotCollection() *mongo.Collection

func (*MongoFactory) NewUserCollection

func (mf *MongoFactory) NewUserCollection() *mongo.Collection

type MongoFactoryConfig

type MongoFactoryConfig struct {
	DatabaseName           string
	SnapshotCollectionName string
	UserCollectionName     string
	DeltaCollectionName    string
}

type TransactionManager

type TransactionManager struct {
	// contains filtered or unexported fields
}

TransactionManager handles MongoDB transactions

func NewTransactionManager

func NewTransactionManager(client *mongo.Client, transactionsEnabled bool) *TransactionManager

func (*TransactionManager) IsInTransaction

func (tm *TransactionManager) IsInTransaction(ctx context.Context) bool

IsInTransaction returns true if the context is currently within a transaction

func (*TransactionManager) WithTransaction

func (tm *TransactionManager) WithTransaction(ctx context.Context, fn func(ctx context.Context) error) error

WithTransaction executes the given function within a transaction. If transactions are disabled, it simply executes the function directly. If a transaction is already in progress (detected via context), it reuses that transaction. Otherwise, it starts a new transaction. On error, the transaction is rolled back. On success, it is committed.