db

Documentation

Index

• Variables
• func Register(models ...interface{})
• type DB
  • func Connect(cfg *config.Config) (*DB, error)
  • func (db *DB) AutoMigrateAll() error
  • func (db *DB) IsProcessed(ctx context.Context, scope, key string) (bool, error)
  • func (db *DB) MarkProcessed(ctx context.Context, scope, key string) error
  • func (db *DB) Transaction(fn func(tx *DB) error) error
• type IdempotencyKey
• type JSONMap
  • func (m *JSONMap) Scan(value interface{}) error
  • func (m JSONMap) Value() (driver.Value, error)

Variables

var (
	Registry = []interface{}{&IdempotencyKey{}}
)

Functions

func Register

func Register(models ...interface{})

Register adds models to the global migration registry.

Types

type DB

type DB struct {
	*gorm.DB
}

DB represents the database connection wrapper.

func Connect

func Connect(cfg *config.Config) (*DB, error)

Connect initializes a database connection based on the provided configuration.

func (*DB) AutoMigrateAll

func (db *DB) AutoMigrateAll() error

AutoMigrate runs the GORM AutoMigrate for all registered models.

func (*DB) IsProcessed

func (db *DB) IsProcessed(ctx context.Context, scope, key string) (bool, error)

IsProcessed checks if an operation has already been completed.

func (*DB) MarkProcessed

func (db *DB) MarkProcessed(ctx context.Context, scope, key string) error

MarkProcessed records that an operation has been completed.

func (*DB) Transaction

func (db *DB) Transaction(fn func(tx *DB) error) error

Transaction executes the given function within a database transaction.

type IdempotencyKey

type IdempotencyKey struct {
	ID        string `gorm:"primaryKey"`
	Scope     string `gorm:"index:idx_scope_key,unique"` // e.g. "workflow_step"
	Key       string `gorm:"index:idx_scope_key,unique"` // e.g. "wfID_stepID"
	CreatedAt time.Time
}

IdempotencyKey prevents duplicate processing of the same operation.

type JSONMap

type JSONMap map[string]string

JSONMap is a custom type for map[string]string that implements GORM scanner/valuer.

func (*JSONMap) Scan

func (m *JSONMap) Scan(value interface{}) error

func (JSONMap) Value

func (m JSONMap) Value() (driver.Value, error)