database

package module

v0.0.0-...-98a3319 Latest Latest Go to latest Published: Dec 24, 2025 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

Database helper

View Source

const MaxAttempts = 1_000_000

View Source

var ErrMaxAttemptsExceeded = errors.New("max numbers of attempts exceeded")

func CreateBatchSize[T any](c *Connection) (size int, err error)

type Config struct {
	Logger           *slog.Logger
	DSN              string      `yaml:"dsn"`
	ConnectionConfig gorm.Config `yaml:"-"`
}

type Connection struct {
	Driver             DriverName
	TransactionCounter atomic.Int64
	Logger             *slog.Logger
	*gorm.DB
}

func SQLite(config Config) (conn *Connection, err error)

Easier local testing Database. Should not be used in production.

func (conn *Connection) Close() (err error)

func (c *Connection) Transaction(ctx context.Context, fc func(tx *gorm.DB) (err error), opts ...*sql.TxOptions) (err error)

type DriverName string

const DriverNameSQLite DriverName = "sqlite"

Path	Synopsis
testsuite