cmds

Documentation

Index

• Variables
• type Dev
  • func NewDev(db *sql.DB, queries *sqlcgen.Queries, ollamaClient *ollama.Client, ...) *Dev
• type Jobs
  • func NewJobs() *Jobs
• type JobsList
  • func NewJobsList(db *sql.DB) *JobsList
• type JobsShow
  • func NewJobsShow(db *sql.DB) *JobsShow
• type Migrate
  • func NewMigrate() *Migrate
• type MigrateCreate
  • func NewMigrateCreate(migrator *database.Migrator) *MigrateCreate
• type MigrateDown
  • func NewMigrateDown(migrator *database.Migrator, logger *slog.Logger) *MigrateDown
• type MigrateRedo
  • func NewMigrateRedo(migrator *database.Migrator, logger *slog.Logger) *MigrateRedo
• type MigrateStatus
  • func NewMigrateStatus(migrator *database.Migrator) *MigrateStatus
• type MigrateUp
  • func NewMigrateUp(migrator *database.Migrator, logger *slog.Logger) *MigrateUp
• type MigrateUpFresh
  • func NewMigrateUpFresh(migrator *database.Migrator, logger *slog.Logger) *MigrateUpFresh
• type Outbox
  • func NewOutbox() *Outbox
• type OutboxReplay
  • func NewOutboxReplay(db *sql.DB, logger *slog.Logger) *OutboxReplay
• type Schedule
  • func NewSchedule(scheduler *schedule.Scheduler) *Schedule
• type Test
  • func NewTest(logger *slog.Logger) *Test
• type TestSubTree
  • func NewTestSubTree(logger *slog.Logger) *TestSubTree

Variables

var (
	ErrInvalidSteps    = errors.New("steps must be a positive number")
	ErrInvalidDownArgs = errors.New("down requires a positive number or *")
)

Types

type Dev

type Dev struct {
	*cobra.Command
}

func NewDev

func NewDev(db *sql.DB, queries *sqlcgen.Queries, ollamaClient *ollama.Client, logger *slog.Logger) *Dev

type Jobs

type Jobs struct {
	*cobra.Command
}

Jobs is the parent command for queue inspection utilities.

func NewJobs

func NewJobs() *Jobs

type JobsList

type JobsList struct {
	*cobra.Command
}

JobsList lists all pending messages in the goqite queue.

func NewJobsList

func NewJobsList(db *sql.DB) *JobsList

type JobsShow

type JobsShow struct {
	*cobra.Command
}

JobsShow displays a single goqite message with full payload.

func NewJobsShow

func NewJobsShow(db *sql.DB) *JobsShow

type Migrate

type Migrate struct {
	*cobra.Command
}

Migrate is a proxy command that dispatches goose operations.

func NewMigrate

func NewMigrate() *Migrate

type MigrateCreate

type MigrateCreate struct{ *cobra.Command }

func NewMigrateCreate

func NewMigrateCreate(migrator *database.Migrator) *MigrateCreate

type MigrateDown

type MigrateDown struct{ *cobra.Command }

func NewMigrateDown

func NewMigrateDown(migrator *database.Migrator, logger *slog.Logger) *MigrateDown

type MigrateRedo

type MigrateRedo struct{ *cobra.Command }

func NewMigrateRedo

func NewMigrateRedo(migrator *database.Migrator, logger *slog.Logger) *MigrateRedo

type MigrateStatus

type MigrateStatus struct{ *cobra.Command }

func NewMigrateStatus

func NewMigrateStatus(migrator *database.Migrator) *MigrateStatus

type MigrateUp

type MigrateUp struct{ *cobra.Command }

func NewMigrateUp

func NewMigrateUp(migrator *database.Migrator, logger *slog.Logger) *MigrateUp

type MigrateUpFresh

type MigrateUpFresh struct{ *cobra.Command }

func NewMigrateUpFresh

func NewMigrateUpFresh(migrator *database.Migrator, logger *slog.Logger) *MigrateUpFresh

type Outbox

type Outbox struct {
	*cobra.Command
}

Outbox is a parent command for outbox dev utilities.

func NewOutbox

func NewOutbox() *Outbox

type OutboxReplay

type OutboxReplay struct {
	*cobra.Command
}

OutboxReplay resets processed_at so the explainer re-processes events.

func NewOutboxReplay

func NewOutboxReplay(db *sql.DB, logger *slog.Logger) *OutboxReplay

type Schedule

type Schedule struct {
	*cobra.Command
}

func NewSchedule

func NewSchedule(scheduler *schedule.Scheduler) *Schedule

type Test

type Test struct {
	*cobra.Command
}

Test command for new commands registration architecture changes.

Will be removed after adds new real production commands.

Added as proof-of-concept

func NewTest

func NewTest(logger *slog.Logger) *Test

type TestSubTree

type TestSubTree struct {
	*cobra.Command
}

TestSubTree command for new commands registration architecture changes.

Will be removed after adds new real production commands.

Added as proof-of-concept

func NewTestSubTree

func NewTestSubTree(logger *slog.Logger) *TestSubTree