workload

Documentation

Index

• Variables
• type AppWrapper
  • func (aw *AppWrapper) Finished() (message string, success, finished 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 ChildWorkloadReconciler
  • func (r *ChildWorkloadReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ChildWorkloadReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var (
	GVK                = workloadv1beta2.GroupVersion.WithKind("AppWrapper")
	WorkloadReconciler = jobframework.NewGenericReconcilerFactory(
		func() jobframework.GenericJob { return &AppWrapper{} },
		func(b *builder.Builder, c client.Client) *builder.Builder {
			return b.Named("AppWrapperWorkload")
		},
	)
)

Types

type AppWrapper

type AppWrapper workloadv1beta2.AppWrapper

func (*AppWrapper) Finished

func (aw *AppWrapper) Finished() (message string, success, finished 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

RestorePodSetsInfo clears the PodSetInfos saved by RunWithPodSetsInfo

func (*AppWrapper) RunWithPodSetsInfo

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

RunWithPodSetsInfo records the assigned PodSetInfos for each component and sets aw.spec.Suspend to false

func (*AppWrapper) Suspend

func (aw *AppWrapper) Suspend()

type ChildWorkloadReconciler

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

ChildWorkloadReconciler reconciles the admission status of an AppWrapper's child workloads

func (*ChildWorkloadReconciler) Reconcile

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

Reconcile propagates the Admission of an AppWrapper to its children's Workload objects

func (*ChildWorkloadReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.