controller

Documentation

Index

• Variables
• type AppWrapper
  • func (aw *AppWrapper) Finished() (metav1.Condition, bool)
  • func (aw *AppWrapper) GVK() schema.GroupVersionKind
  • func (aw *AppWrapper) IsActive() bool
  • func (aw *AppWrapper) IsSuspended() bool
  • func (aw *AppWrapper) Object() client.Object
  • func (aw *AppWrapper) PodSets() []kueue.PodSet
  • func (aw *AppWrapper) PodsReady() bool
  • func (aw *AppWrapper) RestorePodSetsInfo(podSetsInfo []podset.PodSetInfo) bool
  • func (aw *AppWrapper) RunWithPodSetsInfo(podSetsInfo []podset.PodSetInfo) error
  • func (aw *AppWrapper) Suspend()
• type AppWrapperReconciler
  • func (r *AppWrapperReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AppWrapperReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AppWrapperWebhook
  • func (w *AppWrapperWebhook) Default(ctx context.Context, obj runtime.Object) error
  • func (w *AppWrapperWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (w *AppWrapperWebhook) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (w *AppWrapperWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

Variables

var (
	GVK                = workloadv1beta2.GroupVersion.WithKind("AppWrapper")
	WorkloadReconciler = jobframework.NewGenericReconciler(func() jobframework.GenericJob { return &AppWrapper{} }, nil)
)

Types

type AppWrapper

type AppWrapper workloadv1beta2.AppWrapper

func (*AppWrapper) Finished

func (aw *AppWrapper) Finished() (metav1.Condition, bool)

func (*AppWrapper) GVK

func (aw *AppWrapper) GVK() schema.GroupVersionKind

func (*AppWrapper) IsActive

func (aw *AppWrapper) IsActive() bool

func (*AppWrapper) IsSuspended

func (aw *AppWrapper) IsSuspended() bool

func (*AppWrapper) Object

func (aw *AppWrapper) Object() client.Object

func (*AppWrapper) PodSets

func (aw *AppWrapper) PodSets() []kueue.PodSet

func (*AppWrapper) PodsReady

func (aw *AppWrapper) PodsReady() bool

func (*AppWrapper) RestorePodSetsInfo

func (aw *AppWrapper) RestorePodSetsInfo(podSetsInfo []podset.PodSetInfo) bool

func (*AppWrapper) RunWithPodSetsInfo

func (aw *AppWrapper) RunWithPodSetsInfo(podSetsInfo []podset.PodSetInfo) error

func (*AppWrapper) Suspend

func (aw *AppWrapper) Suspend()

type AppWrapperReconciler

type AppWrapperReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

AppWrapperReconciler reconciles an appwrapper

func (*AppWrapperReconciler) Reconcile

func (r *AppWrapperReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles an appwrapper

func (*AppWrapperReconciler) SetupWithManager

func (r *AppWrapperReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type AppWrapperWebhook

type AppWrapperWebhook struct {
	ManageJobsWithoutQueueName bool
}

func (*AppWrapperWebhook) Default

func (w *AppWrapperWebhook) Default(ctx context.Context, obj runtime.Object) error

Default implements webhook.CustomDefaulter so a webhook will be registered for the type

func (*AppWrapperWebhook) ValidateCreate

func (w *AppWrapperWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type

func (*AppWrapperWebhook) ValidateDelete

func (w *AppWrapperWebhook) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type

func (*AppWrapperWebhook) ValidateUpdate

func (w *AppWrapperWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type