database

Documentation

Index

• type CreateRequestParams
• type DBTX
• type Database
  • func NewDatabase(dbPath, dbString string) (*Database, error)
  • func (db *Database) Close() error
  • func (db *Database) WithContext(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)
• type Migration
• type MigrationRunner
  • 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
  • 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
• type UpdateRequestParams

Types

type CreateRequestParams

type CreateRequestParams struct {
	Name        string
	RequestJson interface{}
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Database

type Database struct {
	DB      *sql.DB
	Queries *Queries
	Timeout time.Duration
}

func NewDatabase

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

func (*Database) Close

func (db *Database) Close() error

func (*Database) WithContext

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

type Migration

type Migration struct {
	Version   string
	Filename  string
	UpSQL     string
	DownSQL   string
	AppliedAt *time.Time
	IsApplied bool
}

type MigrationRunner

type MigrationRunner struct {
	// contains filtered or unexported fields
}

func NewMigrationRunner

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

func (*MigrationRunner) EnsureMigrationTable

func (mr *MigrationRunner) EnsureMigrationTable() error

func (*MigrationRunner) GetAppliedMigrations

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

func (*MigrationRunner) GetMigrationStatus

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

func (*MigrationRunner) LoadMigrations

func (mr *MigrationRunner) LoadMigrations() error

func (*MigrationRunner) Up

func (mr *MigrationRunner) Up() error

type Queries

type Queries struct {
	// contains filtered or unexported fields
}

func New

func New(db DBTX) *Queries

func (*Queries) CreateRequest

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

func (*Queries) DeleteRequest

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

func (*Queries) GetRequest

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

func (*Queries) ListRequests

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

func (*Queries) UpdateRequest

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

func (*Queries) WithTx

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

type RequestBlob

type RequestBlob struct {
	Name        string
	CreatedAt   sql.NullTime
	UpdatedAt   sql.NullTime
	RequestJson interface{}
}

type UpdateRequestParams

type UpdateRequestParams struct {
	RequestJson interface{}
	Name        string
}