server

type HTTPMiddleware interface {
	// Return a http handler with middleware as the parent handler
	HandleFunc(http.HandlerFunc) http.HandlerFunc
}

type HTTPRouter interface {
	// Return the CORS origin
	Origin() string

	// Register a function to handle a URL path
	HandleFunc(context.Context, string, http.HandlerFunc)
}

type Logger interface {

	// Emit an informational message
	Print(context.Context, ...any)
}

type PG interface {
	// Return the connection pool
	Conn() pg.PoolConn
}

type PGCallback func(context.Context, any) error

type PGQueue interface {
	Task

	// Return the worker name
	Worker() string

	// Register a ticker with a callback, and return the registered ticker
	RegisterTicker(context.Context, schema.TickerMeta, PGCallback) (*schema.Ticker, error)

	// Register a queue with a callback, and return the registered queue
	RegisterQueue(context.Context, schema.Queue, PGCallback) (*schema.Queue, error)

	// Create a task for a queue with a payload and optional delay, and return it
	CreateTask(context.Context, string, any, time.Duration) (*schema.Task, error)

	// Delete a ticker by name
	DeleteTicker(context.Context, string) error
}

type Plugin interface {
	// Return the unique name for the plugin
	Name() string

	// Return a description of the plugin
	Description() string

	// Create a task from a plugin
	New(context.Context) (Task, error)
}

type Provider interface {
	Task

	// Return a task given a plugin label
	Task(context.Context, string) Task
}

type Task interface {
	// Run a task
	Run(context.Context) error
}