Versions in this module Expand all Collapse all v0 v0.5.0 Dec 5, 2022 Changes in this version + type Code int + const Error + const Skip + const Success + const Unschedulable + const Wait + type CoordinatorConfiguration struct + FilterPlugins []string + PreDequeuePlugins []string + PreFilterPlugins []string + SchedulePeriod time.Duration + ScorePlugins []string + TenantPlugin string + type FilterPlugin interface + Filter func(ctx context.Context, qu *QueueUnit) Status + type Plugin interface + Name func() string + type PluginFactory func(client client.Client, recorder record.EventRecorder) Plugin + type PreDequeuePlugin interface + PreDequeue func(ctx context.Context, qu *QueueUnit) Status + type PreFilterPlugin interface + PreFilter func(ctx context.Context, qu *QueueUnit) Status + type QueueUnit struct + Object client.Object + Owner workqueue.RateLimitingInterface + Priority *int32 + Resources corev1.ResourceList + SchedPolicy *v1.SchedulingPolicy + Specs map[v1.ReplicaType]*v1.ReplicaSpec + SpotResources corev1.ResourceList + Status *v1.JobStatus + Tenant string + func (qu *QueueUnit) Key() string + func (qu *QueueUnit) SpotQueueUnit() *QueueUnit + type QueueUnitScore struct + QueueUnit *QueueUnit + Score int64 + type ScorePlugin interface + Score func(ctx context.Context, qu *QueueUnit) (int64, Status) + type Status interface + AppendReason func(reason string) + AsError func() error + Code func() Code + IsSuccess func() bool + IsUnschedulable func() bool + Message func() string + Reasons func() []string + func NewStatus(code Code, reasons ...string) Status + type TenantPlugin interface + TenantName func(qu *QueueUnit) string
Go to main page