database

Documentation

Index

• func ToViaJSON[T any](source any) (target T, err error)
• type Config
• type DB
  • func Open(ctx context.Context, params Params) (DB, error)
  • func (db DB) Transaction(fn func(tx DB) error) error
  • func (db DB) Upsert(value any) *gorm.DB
  • func (db DB) UpsertInBatches(value any, batchSize int) *gorm.DB
  • func (db DB) WithContext(ctx context.Context) DB
• type Driver
  • func (Driver) SchemaEnum() any
• type Params

Functions

func ToViaJSON

func ToViaJSON[T any](source any) (target T, err error)

Types

type Config

type Config struct {
	Driver Driver `yaml:"driver"`
	DSN    string `` /* 149-byte string literal not displayed */
}

type DB

type DB struct {
	*gorm.DB
}

func Open

func Open(ctx context.Context, params Params) (DB, error)

func (DB) Transaction

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

func (DB) Upsert

func (db DB) Upsert(value any) *gorm.DB

func (DB) UpsertInBatches

func (db DB) UpsertInBatches(value any, batchSize int) *gorm.DB

func (DB) WithContext

func (db DB) WithContext(ctx context.Context) DB

type Driver

type Driver string

func (Driver) SchemaEnum

func (Driver) SchemaEnum() any

type Params

type Params struct {
	Clock    based.Clock  `validate:"required"`
	Logger   *slog.Logger `validate:"required"`
	Config   Config       `validate:"required"`
	Entities []any        `validate:"required"`
}