queue

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

type Executor interface {
	// Triggers the actual job
	Execute() error
	// Exclusive will return true, if the job is an
	// exclusive job and can't be run together with
	// other jobs on the same repository.
	Exclusive() bool
	// Logger returns the logger in the job's context so we can
	// Associate the logs with the actual job.
	Logger() logr.Logger
	// GetJobType() returns the type of the CDR that the job will execute
	GetJobType() v1alpha1.JobType
	// GetJobNamespace() returns the namespace of the CDR that the job will execute
	GetJobNamespace() string
	// GetConcurrencyLimit
	GetConcurrencyLimit() int
	// GetName() string
	GetRepository() string
}

type QueuedJob struct {
	Job Executor
	// contains filtered or unexported fields
}