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()

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()