Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

unitofwork

package

Go to main page

Versions in this module

v0

v0.1.1

Sep 5, 2025

v0.1.0

Jul 11, 2025

v0.0.10

Jun 11, 2025

v0.0.9

Jun 11, 2025

v0.0.8

Jun 11, 2025

v0.0.7

Jun 10, 2025

Changes in this version

+ func ConvertToTypedSlice(input []Entity, elemType reflect.Type) interface

+ func SetUnitOfWorkToContext(ctx context.Context, uow *UnitOfWork, key string) context.Context

+ func WithUnitOfWork(ctx context.Context, db *gorm.DB, fn func(*gorm.DB, *UnitOfWork) error, ...) error

+ type BaseEntity struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID uint

+ Revision int64

+ UpdatedAt time.Time

+ func (b *BaseEntity) GetCreatedAt() time.Time

+ func (b *BaseEntity) GetDeletedAt() gorm.DeletedAt

+ func (b *BaseEntity) GetID() uint

+ func (b *BaseEntity) GetRevision() int64

+ func (b *BaseEntity) GetRevisionNext() int64

+ func (b *BaseEntity) GetTableName() string

+ func (b *BaseEntity) GetUpdatedAt() time.Time

+ func (b *BaseEntity) IsDeleted() bool

+ func (b *BaseEntity) IsNew() bool

+ func (b *BaseEntity) SetCreatedAt(createdAt time.Time)

+ func (b *BaseEntity) SetDeletedAt(deletedAt gorm.DeletedAt)

+ func (b *BaseEntity) SetID(id uint)

+ func (b *BaseEntity) SetRevision(revision int64)

+ func (b *BaseEntity) SetUpdatedAt(updatedAt time.Time)

+ func (b *BaseEntity) Validate() error

+ type BulkDeleteOperation struct

+ func NewBulkDeleteOperation(entities []Entity) *BulkDeleteOperation

+ func (op *BulkDeleteOperation) CanMerge(other Operation) bool

+ func (op *BulkDeleteOperation) Execute(db *gorm.DB) error

+ func (op *BulkDeleteOperation) GetEntities() []Entity

+ func (op *BulkDeleteOperation) GetEntity() Entity

+ func (op *BulkDeleteOperation) GetEntityType() reflect.Type

+ func (op *BulkDeleteOperation) GetOperationType() OperationType

+ func (op *BulkDeleteOperation) Merge(other Operation) Operation

+ func (op *BulkDeleteOperation) SameIdentity(other Operation) bool

+ type BulkInsertOperation struct

+ func NewBulkInsertOperation(entities []Entity, insertOperation *InsertOperation) *BulkInsertOperation

+ func (op *BulkInsertOperation) CanMerge(other Operation) bool

+ func (op *BulkInsertOperation) Execute(db *gorm.DB) error

+ func (op *BulkInsertOperation) GetEntities() []Entity

+ func (op *BulkInsertOperation) GetEntity() Entity

+ func (op *BulkInsertOperation) GetEntityType() reflect.Type

+ func (op *BulkInsertOperation) GetOperationType() OperationType

+ func (op *BulkInsertOperation) Merge(other Operation) Operation

+ func (op *BulkInsertOperation) SameIdentity(other Operation) bool

+ type BulkUpdateOperation struct

+ func NewBulkUpdateOperation(entities []Entity) *BulkUpdateOperation

+ func (op *BulkUpdateOperation) CanMerge(other Operation) bool

+ func (op *BulkUpdateOperation) Execute(db *gorm.DB) error

+ func (op *BulkUpdateOperation) GetEntities() []Entity

+ func (op *BulkUpdateOperation) GetEntity() Entity

+ func (op *BulkUpdateOperation) GetEntityType() reflect.Type

+ func (op *BulkUpdateOperation) GetOperationType() OperationType

+ func (op *BulkUpdateOperation) Merge(other Operation) Operation

+ func (op *BulkUpdateOperation) SameIdentity(other Operation) bool

+ type Callback func(*UnitOfWork) error

+ type Config struct

+ BatchSize int

+ EnableDetailLog bool

+ EnableDirtyCheck bool

+ EnableOperationMerge bool

+ MaxEntityCount int

+ func DefaultConfig() *Config

+ type ConfigOption func(*Config)

+ func WithBatchSize(size int) ConfigOption

+ func WithDetailLog(enabled bool) ConfigOption

+ func WithDirtyCheck(enabled bool) ConfigOption

+ func WithMaxEntityCount(count int) ConfigOption

+ func WithOperationMerge(enabled bool) ConfigOption

+ type ContextUnitOfWork string

+ type DeleteOperation struct

+ func NewDeleteOperation(entity Entity) *DeleteOperation

+ func (op *DeleteOperation) CanMerge(other Operation) bool

+ func (op *DeleteOperation) Execute(db *gorm.DB) error

+ func (op *DeleteOperation) GetEntity() Entity

+ func (op *DeleteOperation) GetEntityType() reflect.Type

+ func (op *DeleteOperation) GetOperationType() OperationType

+ func (op *DeleteOperation) Merge(other Operation) Operation

+ func (op *DeleteOperation) SameIdentity(other Operation) bool

+ type DependencyManager struct

+ func DefaultDependencyManager() *DependencyManager

+ func NewDependencyManager() *DependencyManager

+ func (dm *DependencyManager) Clear()

+ func (dm *DependencyManager) GetAllEntityTypes() []reflect.Type

+ func (dm *DependencyManager) GetDeletionOrder(entities []Entity) ([]Entity, error)

+ func (dm *DependencyManager) GetInsertionOrder(entities []Entity) ([]Entity, error)

+ func (dm *DependencyManager) HasDependency(dependent, dependency reflect.Type) bool

+ func (dm *DependencyManager) RegisterDependency(dependent, dependency reflect.Type)

+ func (dm *DependencyManager) RegisterEntityWeight(entityType reflect.Type, weight int)

+ func (dm *DependencyManager) RemoveDependency(dependent, dependency reflect.Type)

+ type Entity interface

+ GetID func() uint

+ GetTableName func() string

+ IsNew func() bool

+ SetID func(id uint)

+ type EntitySnapshot struct

+ func NewEntitySnapshot(entity Entity) *EntitySnapshot

+ func (s *EntitySnapshot) GetChangedFields(entity Entity) map[string]FieldChange

+ func (s *EntitySnapshot) IsDirty(entity Entity) bool

+ type FieldChange struct

+ FieldName string

+ NewValue interface{}

+ OldValue interface{}

+ Type FieldChangeType

+ type FieldChangeType int

+ const FieldChangeTypeAdded

+ const FieldChangeTypeDeleted

+ const FieldChangeTypeModified

+ func (t FieldChangeType) String() string

+ type HasRevision interface

+ GetRevision func() int64

+ GetRevisionNext func() int64

+ SetRevision func(revision int64)

+ type HasTimestamps interface

+ GetCreatedAt func() time.Time

+ GetUpdatedAt func() time.Time

+ SetCreatedAt func(createdAt time.Time)

+ SetUpdatedAt func(updatedAt time.Time)

+ type InsertOperation struct

+ func NewInsertOperation(entity Entity, uow *UnitOfWork) *InsertOperation

+ func (op *InsertOperation) CanMerge(other Operation) bool

+ func (op *InsertOperation) Execute(db *gorm.DB) error

+ func (op *InsertOperation) GetEntity() Entity

+ func (op *InsertOperation) GetEntityType() reflect.Type

+ func (op *InsertOperation) GetOperationType() OperationType

+ func (op *InsertOperation) Merge(other Operation) Operation

+ func (op *InsertOperation) SameIdentity(other Operation) bool

+ type Manager struct

+ func NewManager(db *gorm.DB, options ...ConfigOption) *Manager

+ func (m *Manager) ExecuteInNewUnitOfWork(fn Callback) error

+ func (m *Manager) ExecuteInUnitOfWork(ctx context.Context, fn Callback) error

+ type Operation interface

+ CanMerge func(other Operation) bool

+ Execute func(db *gorm.DB) error

+ GetEntity func() Entity

+ GetEntityType func() reflect.Type

+ GetOperationType func() OperationType

+ Merge func(other Operation) Operation

+ SameIdentity func(other Operation) bool

+ type OperationType int

+ const OperationTypeBulkDelete

+ const OperationTypeBulkInsert

+ const OperationTypeBulkUpdate

+ const OperationTypeDelete

+ const OperationTypeInsert

+ const OperationTypeUpdate

+ func (t OperationType) String() string

+ type Plugin struct

+ func NewPlugin(options ...PluginOption) *Plugin

+ func (p *Plugin) Initialize(db *gorm.DB) error

+ func (p *Plugin) Name() string

+ type PluginConfig struct

+ AutoDependencyRegistration bool

+ AutoManage bool

+ ContextKey string

+ DependencyMapping map[reflect.Type][]reflect.Type

+ UnitOfWorkConfig *Config

+ func DefaultPluginConfig() *PluginConfig

+ type PluginOption func(*PluginConfig)

+ func WithPluginAutoManage(enabled bool) PluginOption

+ func WithPluginContextKey(key string) PluginOption

+ func WithPluginDependencyMapping(mapping map[reflect.Type][]reflect.Type) PluginOption

+ func WithPluginUnitOfWorkConfig(config *Config) PluginOption

+ type SnapshotManager struct

+ func NewSnapshotManager() *SnapshotManager

+ func (sm *SnapshotManager) Clear()

+ func (sm *SnapshotManager) GetChangedFields(entity Entity) map[string]FieldChange

+ func (sm *SnapshotManager) IsDirty(entity Entity) bool

+ func (sm *SnapshotManager) RemoveSnapshot(entity Entity)

+ func (sm *SnapshotManager) TakeSnapshot(entity Entity)

+ type SoftDelete interface

+ GetDeletedAt func() gorm.DeletedAt

+ IsDeleted func() bool

+ SetDeletedAt func(deletedAt gorm.DeletedAt)

+ type UnitOfWork struct

+ func GetUnitOfWorkFromContext(ctx context.Context, key string) *UnitOfWork

+ func NewUnitOfWork(db *gorm.DB, options ...ConfigOption) *UnitOfWork

+ func (uow *UnitOfWork) Commit() error

+ func (uow *UnitOfWork) Create(entity Entity) error

+ func (uow *UnitOfWork) Delete(entity Entity) error

+ func (uow *UnitOfWork) GetDependencyManager() *DependencyManager

+ func (uow *UnitOfWork) GetStats() map[string]interface{}

+ func (uow *UnitOfWork) IsCommitted() bool

+ func (uow *UnitOfWork) IsRolledBack() bool

+ func (uow *UnitOfWork) Rollback() error

+ func (uow *UnitOfWork) TakeSnapshot(entity Entity)

+ func (uow *UnitOfWork) Update(entity Entity) error

+ func (uow *UnitOfWork) WithContext(ctx context.Context) *UnitOfWork

+ type UpdateOperation struct

+ func NewUpdateOperation(entity Entity, changes map[string]FieldChange) *UpdateOperation

+ func (op *UpdateOperation) CanMerge(other Operation) bool

+ func (op *UpdateOperation) Execute(db *gorm.DB) error

+ func (op *UpdateOperation) GetChanges() map[string]FieldChange

+ func (op *UpdateOperation) GetEntity() Entity

+ func (op *UpdateOperation) GetEntityType() reflect.Type

+ func (op *UpdateOperation) GetOperationType() OperationType

+ func (op *UpdateOperation) Merge(other Operation) Operation

+ func (op *UpdateOperation) SameIdentity(other Operation) bool

+ type Validatable interface

+ Validate func() error