workers

type Config struct {
	PoolSize uint `dm:"pool_size"`
	Logger   *logger.Logger
	Runner   Runner
	// contains filtered or unexported fields
}

type Job struct {
	ID         string       `json:"id"`
	Namespace  string       `json:"namespace"`
	Type       string       `json:"type"`
	ExternalID string       `json:"external_id"`
	Name       string       `json:"name"`
	Version    uint         `json:"version"`
	Origin     string       `json:"origin"`
	Priority   sdk.Priority `json:"priority"`
	Session    uint         `json:"session"`
	Attempt    uint         `json:"attempt"`
	StartedAt  time.Time    `json:"started_at"`
	FinishedAt time.Time    `json:"finished_at"`
}

type Runner interface {
	NextJob(host, worker string) *sdk.Job
	RunJob(logger *logger.Logger, job *sdk.Job) error
	UpdateJob(jtu *sdk.JobToUpdate) (*sdk.Job, *sdk.Job)
}

type WorkerState struct {
	ID          string    `json:"id"`
	CreatedAt   time.Time `json:"created_at"`
	Temporary   bool      `json:"temporary"`
	Interrupted bool      `json:"interrupted"`
	Busy        bool      `json:"busy"`
	Job         *Job      `json:"job"`
	Counter     uint      `json:"counter"`
}

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