database

type Database interface {
	ListWorkers() ([]Worker, error)
	CreateWorker(worker Worker) error
	GetWorker(workerID string) (Worker, error)
	UpdateWorker(worker Worker) error
	DeleteWorker(workerID string) error
}

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

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

type PostgresConfig struct {
	URL          string
	MaxOpenConns int
}

type Worker struct {
	ID          string
	Queue       string
	MaxJobCount int
	Attributes  map[string]string
}