worker

type CloudProvider interface {
	// Runs the job on the cloud provider.
	// Blocks until the job completes.
	RunJob(job Job) error
}

type Event struct {
	Type    string
	Title   string
	Message string
}

type EventStore interface {
	// Creates a new event in the store,
	// ready to be consumed.
	CreateEvent(event Event) error
}

type Info struct {
	Name         string
	Queue        string
	ProcessQueue string
}

type Job struct {
	Name  string
	Image string
	Run   string
}

type JobDependency struct {
	JobID         string
	ExpectFailure bool
}

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

type Recycler interface {
	// Start synchronizing with the recycler.
	// As the synchronization is a loop, it must be called in a goroutine.
	StartSync()
}

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

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

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

type RunStore interface {
	// Actively listens to new runs, and when a new run is available,
	// returns an arbitrary string identifier referencing it.
	// This identifier is used to refer to the run in store operations.
	// Runs returned by this function must be closed when no longer used.
	NextRun() (string, error)

	// Persists the run status in the store.
	// Status can be:
	// - PENDING
	// - RUNNING
	// - SUCCESSFUL
	// - FAILED
	// - CANCELED
	SetRunStatus(runID, status string) error

	// Returns a list of arbitrary string identifiers referencing all
	// jobs contained in the run.
	// A job identifier must be globally unique, meaning that "job1" from "run1"
	// and "job1" from "run2" must have different identifiers.
	GetJobs(runID string) ([]string, error)

	// Returns the Job structure corresponding to the identifier.
	GetJob(jobID string) (Job, error)

	// Persists the job status in the store.
	// Status can be:
	// - PENDING
	// - SKIPPED
	// - RUNNING
	// - SUCCESSFUL
	// - FAILED
	SetJobStatus(jobID, status string) error

	// Returns a list of arbitrary string identifiers referencing all
	// dependencies for the job.
	// A dependency identifier must be globally unique.
	GetJobDependencies(jobID string) ([]JobDependency, error)

	// Closes the run corresponding to the identifier.
	// Post-run operations are done in this function.
	Close(runID string) error
}

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