jobcoordinator

type Code int

type CoordinatorConfiguration struct {
	SchedulePeriod    time.Duration
	TenantPlugin      string
	PreFilterPlugins  []string
	FilterPlugins     []string
	ScorePlugins      []string
	PreDequeuePlugins []string
}

type FilterPlugin interface {
	Filter(ctx context.Context, qu *QueueUnit) Status
	Plugin
}

type Plugin interface {
	Name() string
}

type PluginFactory func(client client.Client, recorder record.EventRecorder) Plugin

type PreDequeuePlugin interface {
	PreDequeue(ctx context.Context, qu *QueueUnit) Status
	Plugin
}

type PreFilterPlugin interface {
	PreFilter(ctx context.Context, qu *QueueUnit) Status
	Plugin
}

type QueueUnit struct {
	Tenant        string
	Priority      *int32
	Object        client.Object
	SchedPolicy   *v1.SchedulingPolicy
	Specs         map[v1.ReplicaType]*v1.ReplicaSpec
	Status        *v1.JobStatus
	Resources     corev1.ResourceList
	SpotResources corev1.ResourceList
	Owner         workqueue.RateLimitingInterface
}

type QueueUnitScore struct {
	QueueUnit *QueueUnit
	Score     int64
}

type ScorePlugin interface {
	Score(ctx context.Context, qu *QueueUnit) (int64, Status)
	Plugin
}

type Status interface {
	// Code returns code of the status.
	Code() Code
	// Message returns a concatenated message on reasons of the status.
	Message() string
	// Reasons returns reasons of the status.
	Reasons() []string
	// AppendReason appends given reason to the status.
	AppendReason(reason string)
	// IsSuccess returns true if and only if "status" is nil or Code is "Success".
	IsSuccess() bool
	// IsUnschedulable returns true if "status" is Unschedulable (Unschedulable or UnschedulableAndUnresolvable).
	IsUnschedulable() bool
	// AsError returns nil if the status is a success; otherwise returns an "error" object
	// with a concatenated message on reasons of the status.
	AsError() error
}

type TenantPlugin interface {
	TenantName(qu *QueueUnit) string
	Plugin
}