database

Jan 23, 2026

Changes in this version

+ type CreateRequestParams struct

+ Name string

+ RequestJson interface{}

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type Database struct

+ DB *sql.DB

+ Queries *Queries

+ Timeout time.Duration

+ func NewDatabase(dbPath, dbString string) (*Database, error)

+ func (db *Database) Close() error

+ func (db *Database) WithContext(ctx context.Context, timeoutSec time.Duration) (context.Context, context.CancelFunc)

+ type Migration struct

+ AppliedAt *time.Time

+ DownSQL string

+ Filename string

+ IsApplied bool

+ UpSQL string

+ Version string

+ type MigrationRunner struct

+ func NewMigrationRunner(db *sql.DB, _ string) *MigrationRunner

+ func (mr *MigrationRunner) EnsureMigrationTable() error

+ func (mr *MigrationRunner) GetAppliedMigrations() (map[string]bool, error)

+ func (mr *MigrationRunner) GetMigrationStatus() ([]Migration, error)

+ func (mr *MigrationRunner) LoadMigrations() error

+ func (mr *MigrationRunner) Up() error

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CreateRequest(ctx context.Context, arg CreateRequestParams) (RequestBlob, error)

+ func (q *Queries) DeleteRequest(ctx context.Context, name string) error

+ func (q *Queries) GetRequest(ctx context.Context, name string) (RequestBlob, error)

+ func (q *Queries) ListRequests(ctx context.Context) ([]RequestBlob, error)

+ func (q *Queries) UpdateRequest(ctx context.Context, arg UpdateRequestParams) (RequestBlob, error)

+ func (q *Queries) WithTx(tx *sql.Tx) *Queries

+ type RequestBlob struct

+ CreatedAt sql.NullTime

+ Name string

+ RequestJson interface{}

+ UpdatedAt sql.NullTime

+ type UpdateRequestParams struct

+ Name string

+ RequestJson interface{}