v1beta1

package
v0.37.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 23, 2026 License: Apache-2.0 Imports: 9 Imported by: 1,030

Documentation

Index

Constants

View Source 
const (
	// WorkloadMaxPodGroupTemplates is the maximum number of pod group templates per Workload.
	WorkloadMaxPodGroupTemplates = 8
	// WorkloadMaxTreeDepth is the maximum allowed depth for a tree of (composite) pod group templates in a Workload.
	WorkloadMaxTreeDepth = 4
)
View Source 
const (
	// PodGroupInitiallyScheduled represents status of the scheduling process for this PodGroup till first success.
	PodGroupInitiallyScheduled string = "PodGroupInitiallyScheduled"
	// DisruptionTarget indicates the PodGroup is about to be terminated due to disruption
	// such as preemption.
	DisruptionTarget string = "DisruptionTarget"
)

Well-known condition types for PodGroups.

View Source 
const (
	// Unschedulable reason in the PodGroupInitiallyScheduled condition indicates that the PodGroup cannot be scheduled
	// due to resource constraints, affinity/anti-affinity rules, or insufficient capacity for the PodGroup.
	PodGroupReasonUnschedulable string = "Unschedulable"
	// SchedulerError reason in the PodGroupInitiallyScheduled condition means that some internal error happens
	// during scheduling, for example due to nodeAffinity parsing errors.
	PodGroupReasonSchedulerError string = "SchedulerError"
	// PreemptionByScheduler reason in the DisruptionTarget condition indicates the PodGroup was preempted
	// to make room for higher-priority PodGroups or Pods.
	PodGroupReasonPreemptionByScheduler string = "PreemptionByScheduler"
)

Well-known condition reasons for PodGroups.

View Source 
const GroupName = "scheduling.k8s.io"

GroupName is the group name use in this package

View Source 
const MaxPodGroupResourceClaims = 4

MaxPodGroupResourceClaims is the maximum number of resource claims for a PodGroup or a Workload's PodGroupTemplate.

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1beta1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AllCompositeDisruptionMode added in v0.37.0 

type AllCompositeDisruptionMode struct {
}

AllCompositeDisruptionMode means that children of a CompositePodGroup can only be disrupted or preempted together.

func (*AllCompositeDisruptionMode) DeepCopy added in v0.37.0 

func (in *AllCompositeDisruptionMode) DeepCopy() *AllCompositeDisruptionMode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AllCompositeDisruptionMode.

func (*AllCompositeDisruptionMode) DeepCopyInto added in v0.37.0 

func (in *AllCompositeDisruptionMode) DeepCopyInto(out *AllCompositeDisruptionMode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AllCompositeDisruptionMode) Marshal added in v0.37.0 

func (m *AllCompositeDisruptionMode) Marshal() (dAtA []byte, err error)

func (*AllCompositeDisruptionMode) MarshalTo added in v0.37.0 

func (m *AllCompositeDisruptionMode) MarshalTo(dAtA []byte) (int, error)

func (*AllCompositeDisruptionMode) MarshalToSizedBuffer added in v0.37.0 

func (m *AllCompositeDisruptionMode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (AllCompositeDisruptionMode) OpenAPIModelName added in v0.37.0 

func (in AllCompositeDisruptionMode) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*AllCompositeDisruptionMode) Reset added in v0.37.0 

func (m *AllCompositeDisruptionMode) Reset()

func (*AllCompositeDisruptionMode) Size added in v0.37.0 

func (m *AllCompositeDisruptionMode) Size() (n int)

func (*AllCompositeDisruptionMode) String added in v0.37.0 

func (this *AllCompositeDisruptionMode) String() string

func (AllCompositeDisruptionMode) SwaggerDoc added in v0.37.0 

func (AllCompositeDisruptionMode) SwaggerDoc() map[string]string

func (*AllCompositeDisruptionMode) Unmarshal added in v0.37.0 

func (m *AllCompositeDisruptionMode) Unmarshal(dAtA []byte) error

type AllDisruptionMode added in v0.37.0 

type AllDisruptionMode struct {
}

AllDisruptionMode specifies that children can only be disrupted together.

func (*AllDisruptionMode) DeepCopy added in v0.37.0 

func (in *AllDisruptionMode) DeepCopy() *AllDisruptionMode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AllDisruptionMode.

func (*AllDisruptionMode) DeepCopyInto added in v0.37.0 

func (in *AllDisruptionMode) DeepCopyInto(out *AllDisruptionMode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AllDisruptionMode) Marshal added in v0.37.0 

func (m *AllDisruptionMode) Marshal() (dAtA []byte, err error)

func (*AllDisruptionMode) MarshalTo added in v0.37.0 

func (m *AllDisruptionMode) MarshalTo(dAtA []byte) (int, error)

func (*AllDisruptionMode) MarshalToSizedBuffer added in v0.37.0 

func (m *AllDisruptionMode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (AllDisruptionMode) OpenAPIModelName added in v0.37.0 

func (in AllDisruptionMode) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*AllDisruptionMode) Reset added in v0.37.0 

func (m *AllDisruptionMode) Reset()

func (*AllDisruptionMode) Size added in v0.37.0 

func (m *AllDisruptionMode) Size() (n int)

func (*AllDisruptionMode) String added in v0.37.0 

func (this *AllDisruptionMode) String() string

func (AllDisruptionMode) SwaggerDoc added in v0.37.0 

func (AllDisruptionMode) SwaggerDoc() map[string]string

func (*AllDisruptionMode) Unmarshal added in v0.37.0 

func (m *AllDisruptionMode) Unmarshal(dAtA []byte) error

type BasicSchedulingPolicy added in v0.37.0 

type BasicSchedulingPolicy struct {
}

BasicSchedulingPolicy indicates that standard Kubernetes scheduling behavior should be used.

func (*BasicSchedulingPolicy) DeepCopy added in v0.37.0 

func (in *BasicSchedulingPolicy) DeepCopy() *BasicSchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BasicSchedulingPolicy.

func (*BasicSchedulingPolicy) DeepCopyInto added in v0.37.0 

func (in *BasicSchedulingPolicy) DeepCopyInto(out *BasicSchedulingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BasicSchedulingPolicy) Marshal added in v0.37.0 

func (m *BasicSchedulingPolicy) Marshal() (dAtA []byte, err error)

func (*BasicSchedulingPolicy) MarshalTo added in v0.37.0 

func (m *BasicSchedulingPolicy) MarshalTo(dAtA []byte) (int, error)

func (*BasicSchedulingPolicy) MarshalToSizedBuffer added in v0.37.0 

func (m *BasicSchedulingPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (BasicSchedulingPolicy) OpenAPIModelName added in v0.37.0 

func (in BasicSchedulingPolicy) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*BasicSchedulingPolicy) Reset added in v0.37.0 

func (m *BasicSchedulingPolicy) Reset()

func (*BasicSchedulingPolicy) Size added in v0.37.0 

func (m *BasicSchedulingPolicy) Size() (n int)

func (*BasicSchedulingPolicy) String added in v0.37.0 

func (this *BasicSchedulingPolicy) String() string

func (BasicSchedulingPolicy) SwaggerDoc added in v0.37.0 

func (BasicSchedulingPolicy) SwaggerDoc() map[string]string

func (*BasicSchedulingPolicy) Unmarshal added in v0.37.0 

func (m *BasicSchedulingPolicy) Unmarshal(dAtA []byte) error

type CompositeBasicSchedulingPolicy added in v0.37.0 

type CompositeBasicSchedulingPolicy struct {
}

CompositeBasicSchedulingPolicy indicates that the groups belonging to the composite group should be scheduled independently.

func (*CompositeBasicSchedulingPolicy) DeepCopy added in v0.37.0 

func (in *CompositeBasicSchedulingPolicy) DeepCopy() *CompositeBasicSchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompositeBasicSchedulingPolicy.

func (*CompositeBasicSchedulingPolicy) DeepCopyInto added in v0.37.0 

func (in *CompositeBasicSchedulingPolicy) DeepCopyInto(out *CompositeBasicSchedulingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CompositeBasicSchedulingPolicy) Marshal added in v0.37.0 

func (m *CompositeBasicSchedulingPolicy) Marshal() (dAtA []byte, err error)

func (*CompositeBasicSchedulingPolicy) MarshalTo added in v0.37.0 

func (m *CompositeBasicSchedulingPolicy) MarshalTo(dAtA []byte) (int, error)

func (*CompositeBasicSchedulingPolicy) MarshalToSizedBuffer added in v0.37.0 

func (m *CompositeBasicSchedulingPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (CompositeBasicSchedulingPolicy) OpenAPIModelName added in v0.37.0 

func (in CompositeBasicSchedulingPolicy) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*CompositeBasicSchedulingPolicy) Reset added in v0.37.0 

func (m *CompositeBasicSchedulingPolicy) Reset()

func (*CompositeBasicSchedulingPolicy) Size added in v0.37.0 

func (m *CompositeBasicSchedulingPolicy) Size() (n int)

func (*CompositeBasicSchedulingPolicy) String added in v0.37.0 

func (this *CompositeBasicSchedulingPolicy) String() string

func (CompositeBasicSchedulingPolicy) SwaggerDoc added in v0.37.0 

func (CompositeBasicSchedulingPolicy) SwaggerDoc() map[string]string

func (*CompositeBasicSchedulingPolicy) Unmarshal added in v0.37.0 

func (m *CompositeBasicSchedulingPolicy) Unmarshal(dAtA []byte) error

type CompositeDisruptionMode added in v0.37.0 

type CompositeDisruptionMode struct {
	// single specifies that children groups can be disrupted independently from each other.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	Single *SingleCompositeDisruptionMode `json:"single,omitempty" protobuf:"bytes,1,opt,name=single"`

	// all specifies that all children groups can only be disrupted together.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	All *AllCompositeDisruptionMode `json:"all,omitempty" protobuf:"bytes,2,opt,name=all"`
}

CompositeDisruptionMode defines how individual entities within a composite pod group can be disrupted. Exactly one mode must be set.

+union

func (*CompositeDisruptionMode) DeepCopy added in v0.37.0 

func (in *CompositeDisruptionMode) DeepCopy() *CompositeDisruptionMode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompositeDisruptionMode.

func (*CompositeDisruptionMode) DeepCopyInto added in v0.37.0 

func (in *CompositeDisruptionMode) DeepCopyInto(out *CompositeDisruptionMode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CompositeDisruptionMode) Marshal added in v0.37.0 

func (m *CompositeDisruptionMode) Marshal() (dAtA []byte, err error)

func (*CompositeDisruptionMode) MarshalTo added in v0.37.0 

func (m *CompositeDisruptionMode) MarshalTo(dAtA []byte) (int, error)

func (*CompositeDisruptionMode) MarshalToSizedBuffer added in v0.37.0 

func (m *CompositeDisruptionMode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (CompositeDisruptionMode) OpenAPIModelName added in v0.37.0 

func (in CompositeDisruptionMode) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*CompositeDisruptionMode) Reset added in v0.37.0 

func (m *CompositeDisruptionMode) Reset()

func (*CompositeDisruptionMode) Size added in v0.37.0 

func (m *CompositeDisruptionMode) Size() (n int)

func (*CompositeDisruptionMode) String added in v0.37.0 

func (this *CompositeDisruptionMode) String() string

func (CompositeDisruptionMode) SwaggerDoc added in v0.37.0 

func (CompositeDisruptionMode) SwaggerDoc() map[string]string

func (*CompositeDisruptionMode) Unmarshal added in v0.37.0 

func (m *CompositeDisruptionMode) Unmarshal(dAtA []byte) error

type CompositeGangSchedulingPolicy added in v0.37.0 

type CompositeGangSchedulingPolicy struct {
	// minGroupCount is the minimum number of child groups that must be schedulable
	// or scheduled at the same time for the scheduler to admit the entire group.
	// It must be a positive integer.
	//
	// +required
	// +k8s:required
	// +k8s:minimum=1
	MinGroupCount int32 `json:"minGroupCount" protobuf:"varint,1,req,name=minGroupCount"`
}

CompositeGangSchedulingPolicy indicates that the groups belonging to the composite group should be scheduled using all-or-nothing semantics.

func (*CompositeGangSchedulingPolicy) DeepCopy added in v0.37.0 

func (in *CompositeGangSchedulingPolicy) DeepCopy() *CompositeGangSchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompositeGangSchedulingPolicy.

func (*CompositeGangSchedulingPolicy) DeepCopyInto added in v0.37.0 

func (in *CompositeGangSchedulingPolicy) DeepCopyInto(out *CompositeGangSchedulingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CompositeGangSchedulingPolicy) Marshal added in v0.37.0 

func (m *CompositeGangSchedulingPolicy) Marshal() (dAtA []byte, err error)

func (*CompositeGangSchedulingPolicy) MarshalTo added in v0.37.0 

func (m *CompositeGangSchedulingPolicy) MarshalTo(dAtA []byte) (int, error)

func (*CompositeGangSchedulingPolicy) MarshalToSizedBuffer added in v0.37.0 

func (m *CompositeGangSchedulingPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (CompositeGangSchedulingPolicy) OpenAPIModelName added in v0.37.0 

func (in CompositeGangSchedulingPolicy) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*CompositeGangSchedulingPolicy) Reset added in v0.37.0 

func (m *CompositeGangSchedulingPolicy) Reset()

func (*CompositeGangSchedulingPolicy) Size added in v0.37.0 

func (m *CompositeGangSchedulingPolicy) Size() (n int)

func (*CompositeGangSchedulingPolicy) String added in v0.37.0 

func (this *CompositeGangSchedulingPolicy) String() string

func (CompositeGangSchedulingPolicy) SwaggerDoc added in v0.37.0 

func (CompositeGangSchedulingPolicy) SwaggerDoc() map[string]string

func (*CompositeGangSchedulingPolicy) Unmarshal added in v0.37.0 

func (m *CompositeGangSchedulingPolicy) Unmarshal(dAtA []byte) error

type CompositePodGroupSchedulingConstraints added in v0.37.0 

type CompositePodGroupSchedulingConstraints struct {
	// topology defines the topology constraints for the composite pod group.
	// Currently only a single topology constraint can be specified. This may change in the future.
	//
	// +optional
	// +k8s:optional
	// +k8s:maxItems=1
	// +listType=atomic
	// +k8s:listType=atomic
	Topology []TopologyConstraint `json:"topology,omitempty" protobuf:"bytes,1,rep,name=topology"`
}

CompositePodGroupSchedulingConstraints defines scheduling constraints (e.g. topology) for a CompositePodGroup.

func (*CompositePodGroupSchedulingConstraints) DeepCopy added in v0.37.0 

func (in *CompositePodGroupSchedulingConstraints) DeepCopy() *CompositePodGroupSchedulingConstraints

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompositePodGroupSchedulingConstraints.

func (*CompositePodGroupSchedulingConstraints) DeepCopyInto added in v0.37.0 

func (in *CompositePodGroupSchedulingConstraints) DeepCopyInto(out *CompositePodGroupSchedulingConstraints)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CompositePodGroupSchedulingConstraints) Marshal added in v0.37.0 

func (m *CompositePodGroupSchedulingConstraints) Marshal() (dAtA []byte, err error)

func (*CompositePodGroupSchedulingConstraints) MarshalTo added in v0.37.0 

func (m *CompositePodGroupSchedulingConstraints) MarshalTo(dAtA []byte) (int, error)

func (*CompositePodGroupSchedulingConstraints) MarshalToSizedBuffer added in v0.37.0 

func (m *CompositePodGroupSchedulingConstraints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (CompositePodGroupSchedulingConstraints) OpenAPIModelName added in v0.37.0 

func (in CompositePodGroupSchedulingConstraints) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*CompositePodGroupSchedulingConstraints) Reset added in v0.37.0 

func (m *CompositePodGroupSchedulingConstraints) Reset()

func (*CompositePodGroupSchedulingConstraints) Size added in v0.37.0 

func (m *CompositePodGroupSchedulingConstraints) Size() (n int)

func (*CompositePodGroupSchedulingConstraints) String added in v0.37.0 

func (this *CompositePodGroupSchedulingConstraints) String() string

func (CompositePodGroupSchedulingConstraints) SwaggerDoc added in v0.37.0 

func (CompositePodGroupSchedulingConstraints) SwaggerDoc() map[string]string

func (*CompositePodGroupSchedulingConstraints) Unmarshal added in v0.37.0 

func (m *CompositePodGroupSchedulingConstraints) Unmarshal(dAtA []byte) error

type CompositePodGroupSchedulingPolicy added in v0.37.0 

type CompositePodGroupSchedulingPolicy struct {
	// basic specifies that the groups of this composite group should be scheduled independently.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	// +k8s:unionMember
	Basic *CompositeBasicSchedulingPolicy `json:"basic,omitempty" protobuf:"bytes,1,opt,name=basic"`

	// gang specifies that the groups of this composite group should be scheduled using
	// all-or-nothing semantics.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	// +k8s:update=NoSet
	// +k8s:update=NoUnset
	Gang *CompositeGangSchedulingPolicy `json:"gang,omitempty" protobuf:"bytes,2,opt,name=gang"`
}

CompositePodGroupSchedulingPolicy defines the scheduling configuration for a CompositePodGroup. Exactly one policy must be set.

+union

func (*CompositePodGroupSchedulingPolicy) DeepCopy added in v0.37.0 

func (in *CompositePodGroupSchedulingPolicy) DeepCopy() *CompositePodGroupSchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompositePodGroupSchedulingPolicy.

func (*CompositePodGroupSchedulingPolicy) DeepCopyInto added in v0.37.0 

func (in *CompositePodGroupSchedulingPolicy) DeepCopyInto(out *CompositePodGroupSchedulingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CompositePodGroupSchedulingPolicy) Marshal added in v0.37.0 

func (m *CompositePodGroupSchedulingPolicy) Marshal() (dAtA []byte, err error)

func (*CompositePodGroupSchedulingPolicy) MarshalTo added in v0.37.0 

func (m *CompositePodGroupSchedulingPolicy) MarshalTo(dAtA []byte) (int, error)

func (*CompositePodGroupSchedulingPolicy) MarshalToSizedBuffer added in v0.37.0 

func (m *CompositePodGroupSchedulingPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (CompositePodGroupSchedulingPolicy) OpenAPIModelName added in v0.37.0 

func (in CompositePodGroupSchedulingPolicy) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*CompositePodGroupSchedulingPolicy) Reset added in v0.37.0 

func (m *CompositePodGroupSchedulingPolicy) Reset()

func (*CompositePodGroupSchedulingPolicy) Size added in v0.37.0 

func (m *CompositePodGroupSchedulingPolicy) Size() (n int)

func (*CompositePodGroupSchedulingPolicy) String added in v0.37.0 

func (this *CompositePodGroupSchedulingPolicy) String() string

func (CompositePodGroupSchedulingPolicy) SwaggerDoc added in v0.37.0 

func (CompositePodGroupSchedulingPolicy) SwaggerDoc() map[string]string

func (*CompositePodGroupSchedulingPolicy) Unmarshal added in v0.37.0 

func (m *CompositePodGroupSchedulingPolicy) Unmarshal(dAtA []byte) error

type CompositePodGroupTemplate added in v0.37.0 

type CompositePodGroupTemplate struct {
	// name is a unique identifier for the CompositePodGroupTemplate within the Workload.
	// It must be a DNS label. This field is required.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-short-name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// schedulingPolicy defines the scheduling policy for this template.
	//
	// +required
	SchedulingPolicy CompositePodGroupSchedulingPolicy `json:"schedulingPolicy" protobuf:"bytes,2,opt,name=schedulingPolicy"`

	// schedulingConstraints defines optional scheduling constraints (e.g. topology) for this CompositePodGroupTemplate.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	SchedulingConstraints *CompositePodGroupSchedulingConstraints `json:"schedulingConstraints,omitempty" protobuf:"bytes,3,opt,name=schedulingConstraints"`

	// disruptionMode defines the mode in which a given CompositePodGroup can be disrupted.
	// One of Single, All.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	DisruptionMode *CompositeDisruptionMode `json:"disruptionMode,omitempty" protobuf:"bytes,4,opt,name=disruptionMode"`

	// priorityClassName indicates the priority that should be considered when scheduling
	// a composite pod group created from this template. If no priority class is specified,
	// admission control can set this to the global default priority class if it exists.
	// Otherwise, composite pod groups created from this template will have the priority set
	// to zero.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:format=k8s-long-name
	// +k8s:immutable
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,5,opt,name=priorityClassName"`

	// priority is the value of priority of composite pod groups created from this template.
	// Various system components use this field to find the priority of the composite pod group.
	// When Priority Admission Controller is enabled, it prevents users from setting this field.
	// The admission controller populates this field from PriorityClassName.
	// The higher the value, the higher the priority.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:maximum=1000000000 # HighestUserDefinablePriority
	// +k8s:immutable
	Priority *int32 `json:"priority,omitempty" protobuf:"varint,6,opt,name=priority"`

	// preemptionPolicy is the Policy for preempting pods/podgroups with lower priority.
	// One of Never, PreemptLowerPriority.
	// This field is immutable.
	// This field is available only when the PodGroupPreemptionPolicy feature gate is enabled.
	//
	// +featureGate=PodGroupPreemptionPolicy
	// +optional
	// +k8s:immutable
	// +k8s:ifDisabled("PodGroupPreemptionPolicy")=+k8s:forbidden
	// +k8s:ifEnabled("PodGroupPreemptionPolicy")=+k8s:optional
	PreemptionPolicy *PreemptionPolicy `json:"preemptionPolicy,omitempty" protobuf:"bytes,7,opt,name=preemptionPolicy"`

	// podGroupTemplates is the list of templates for children PodGroups.
	// The maximum number of templates is 8. At least one entry in CompositePodGroupTemplates
	// or PodGroupTemplates must be set.
	//
	// +optional
	// +listType=map
	// +listMapKey=name
	// +k8s:optional
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=8
	// +k8s:update=NoAddItem
	// +k8s:update=NoRemoveItem
	PodGroupTemplates []PodGroupTemplate `json:"podGroupTemplates,omitempty" protobuf:"bytes,8,rep,name=podGroupTemplates"`

	// compositePodGroupTemplates is the list of templates for children CompositePodGroups.
	// The maximum number of templates is 8. At least one entry in CompositePodGroupTemplates
	// or PodGroupTemplates must be set.
	//
	// +optional
	// +listType=map
	// +listMapKey=name
	// +k8s:optional
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=8
	// +k8s:update=NoAddItem
	// +k8s:update=NoRemoveItem
	CompositePodGroupTemplates []CompositePodGroupTemplate `json:"compositePodGroupTemplates,omitempty" protobuf:"bytes,9,rep,name=compositePodGroupTemplates"`
}

CompositePodGroupTemplate represents a template for a CompositePodGroup with a scheduling policy.

func (*CompositePodGroupTemplate) DeepCopy added in v0.37.0 

func (in *CompositePodGroupTemplate) DeepCopy() *CompositePodGroupTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompositePodGroupTemplate.

func (*CompositePodGroupTemplate) DeepCopyInto added in v0.37.0 

func (in *CompositePodGroupTemplate) DeepCopyInto(out *CompositePodGroupTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CompositePodGroupTemplate) Marshal added in v0.37.0 

func (m *CompositePodGroupTemplate) Marshal() (dAtA []byte, err error)

func (*CompositePodGroupTemplate) MarshalTo added in v0.37.0 

func (m *CompositePodGroupTemplate) MarshalTo(dAtA []byte) (int, error)

func (*CompositePodGroupTemplate) MarshalToSizedBuffer added in v0.37.0 

func (m *CompositePodGroupTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (CompositePodGroupTemplate) OpenAPIModelName added in v0.37.0 

func (in CompositePodGroupTemplate) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*CompositePodGroupTemplate) Reset added in v0.37.0 

func (m *CompositePodGroupTemplate) Reset()

func (*CompositePodGroupTemplate) Size added in v0.37.0 

func (m *CompositePodGroupTemplate) Size() (n int)

func (*CompositePodGroupTemplate) String added in v0.37.0 

func (this *CompositePodGroupTemplate) String() string

func (CompositePodGroupTemplate) SwaggerDoc added in v0.37.0 

func (CompositePodGroupTemplate) SwaggerDoc() map[string]string

func (*CompositePodGroupTemplate) Unmarshal added in v0.37.0 

func (m *CompositePodGroupTemplate) Unmarshal(dAtA []byte) error

type DisruptionMode added in v0.37.0 

type DisruptionMode struct {
	// single specifies that children can be disrupted independently from each other.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	Single *SingleDisruptionMode `json:"single,omitempty" protobuf:"bytes,1,opt,name=single"`

	// all specifies that all children can only be disrupted together.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	All *AllDisruptionMode `json:"all,omitempty" protobuf:"bytes,2,opt,name=all"`
}

DisruptionMode defines how individual entities within a group can be disrupted. Exactly one mode can be set.

+union

func (*DisruptionMode) DeepCopy added in v0.37.0 

func (in *DisruptionMode) DeepCopy() *DisruptionMode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DisruptionMode.

func (*DisruptionMode) DeepCopyInto added in v0.37.0 

func (in *DisruptionMode) DeepCopyInto(out *DisruptionMode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DisruptionMode) Marshal added in v0.37.0 

func (m *DisruptionMode) Marshal() (dAtA []byte, err error)

func (*DisruptionMode) MarshalTo added in v0.37.0 

func (m *DisruptionMode) MarshalTo(dAtA []byte) (int, error)

func (*DisruptionMode) MarshalToSizedBuffer added in v0.37.0 

func (m *DisruptionMode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (DisruptionMode) OpenAPIModelName added in v0.37.0 

func (in DisruptionMode) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*DisruptionMode) Reset added in v0.37.0 

func (m *DisruptionMode) Reset()

func (*DisruptionMode) Size added in v0.37.0 

func (m *DisruptionMode) Size() (n int)

func (*DisruptionMode) String added in v0.37.0 

func (this *DisruptionMode) String() string

func (DisruptionMode) SwaggerDoc added in v0.37.0 

func (DisruptionMode) SwaggerDoc() map[string]string

func (*DisruptionMode) Unmarshal added in v0.37.0 

func (m *DisruptionMode) Unmarshal(dAtA []byte) error

type GangSchedulingPolicy added in v0.37.0 

type GangSchedulingPolicy struct {
	// minCount is the minimum number of pods that must be schedulable or scheduled
	// at the same time for the scheduler to admit the entire group.
	// It must be a positive integer. This field is mutable to support workload scaling.
	//
	// Note that the scheduler operates on an eventually consistent model. Updates
	// to minCount may not be immediately reflected in scheduling decisions due to
	// propagation delays. If minCount is updated while a scheduling cycle is in
	// progress for that group, the new value may not take effect until the next
	// cycle. Moreover, minCount is only enforced during scheduling, meaning that
	// modifications to this field do not affect already-scheduled pods, applying
	// only to those evaluated in future cycles.
	//
	// +required
	// +k8s:required
	// +k8s:minimum=1
	MinCount int32 `json:"minCount" protobuf:"varint,1,opt,name=minCount"`
}

GangSchedulingPolicy defines the parameters for gang scheduling.

func (*GangSchedulingPolicy) DeepCopy added in v0.37.0 

func (in *GangSchedulingPolicy) DeepCopy() *GangSchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GangSchedulingPolicy.

func (*GangSchedulingPolicy) DeepCopyInto added in v0.37.0 

func (in *GangSchedulingPolicy) DeepCopyInto(out *GangSchedulingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GangSchedulingPolicy) Marshal added in v0.37.0 

func (m *GangSchedulingPolicy) Marshal() (dAtA []byte, err error)

func (*GangSchedulingPolicy) MarshalTo added in v0.37.0 

func (m *GangSchedulingPolicy) MarshalTo(dAtA []byte) (int, error)

func (*GangSchedulingPolicy) MarshalToSizedBuffer added in v0.37.0 

func (m *GangSchedulingPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (GangSchedulingPolicy) OpenAPIModelName added in v0.37.0 

func (in GangSchedulingPolicy) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*GangSchedulingPolicy) Reset added in v0.37.0 

func (m *GangSchedulingPolicy) Reset()

func (*GangSchedulingPolicy) Size added in v0.37.0 

func (m *GangSchedulingPolicy) Size() (n int)

func (*GangSchedulingPolicy) String added in v0.37.0 

func (this *GangSchedulingPolicy) String() string

func (GangSchedulingPolicy) SwaggerDoc added in v0.37.0 

func (GangSchedulingPolicy) SwaggerDoc() map[string]string

func (*GangSchedulingPolicy) Unmarshal added in v0.37.0 

func (m *GangSchedulingPolicy) Unmarshal(dAtA []byte) error

type PodGroup added in v0.37.0 

type PodGroup struct {
	metav1.TypeMeta `json:""`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	//
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec defines the desired state of the PodGroup.
	//
	// +required
	Spec PodGroupSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`

	// status represents the current observed state of the PodGroup.
	//
	// +optional
	Status PodGroupStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

PodGroup represents a runtime instance of pods grouped together. PodGroups are created by workload controllers (Job, LWS, JobSet, etc...) from Workload.podGroupTemplates. PodGroup API enablement is toggled by the GenericWorkload feature gate.

func (*PodGroup) APILifecycleDeprecated added in v0.37.0 

func (in *PodGroup) APILifecycleDeprecated() (major, minor int)

APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.

func (*PodGroup) APILifecycleIntroduced added in v0.37.0 

func (in *PodGroup) APILifecycleIntroduced() (major, minor int)

APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.

func (*PodGroup) APILifecycleRemoved added in v0.37.0 

func (in *PodGroup) APILifecycleRemoved() (major, minor int)

APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.

func (*PodGroup) DeepCopy added in v0.37.0 

func (in *PodGroup) DeepCopy() *PodGroup

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroup.

func (*PodGroup) DeepCopyInto added in v0.37.0 

func (in *PodGroup) DeepCopyInto(out *PodGroup)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroup) DeepCopyObject added in v0.37.0 

func (in *PodGroup) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*PodGroup) Marshal added in v0.37.0 

func (m *PodGroup) Marshal() (dAtA []byte, err error)

func (*PodGroup) MarshalTo added in v0.37.0 

func (m *PodGroup) MarshalTo(dAtA []byte) (int, error)

func (*PodGroup) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroup) OpenAPIModelName added in v0.37.0 

func (in PodGroup) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroup) Reset added in v0.37.0 

func (m *PodGroup) Reset()

func (*PodGroup) Size added in v0.37.0 

func (m *PodGroup) Size() (n int)

func (*PodGroup) String added in v0.37.0 

func (this *PodGroup) String() string

func (PodGroup) SwaggerDoc added in v0.37.0 

func (PodGroup) SwaggerDoc() map[string]string

func (*PodGroup) Unmarshal added in v0.37.0 

func (m *PodGroup) Unmarshal(dAtA []byte) error

type PodGroupList added in v0.37.0 

type PodGroupList struct {
	metav1.TypeMeta `json:""`
	// Standard list metadata.
	//
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// Items is the list of PodGroups.
	Items []PodGroup `json:"items" protobuf:"bytes,2,rep,name=items"`
}

PodGroupList contains a list of PodGroup resources.

func (*PodGroupList) APILifecycleDeprecated added in v0.37.0 

func (in *PodGroupList) APILifecycleDeprecated() (major, minor int)

APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.

func (*PodGroupList) APILifecycleIntroduced added in v0.37.0 

func (in *PodGroupList) APILifecycleIntroduced() (major, minor int)

APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.

func (*PodGroupList) APILifecycleRemoved added in v0.37.0 

func (in *PodGroupList) APILifecycleRemoved() (major, minor int)

APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.

func (*PodGroupList) DeepCopy added in v0.37.0 

func (in *PodGroupList) DeepCopy() *PodGroupList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupList.

func (*PodGroupList) DeepCopyInto added in v0.37.0 

func (in *PodGroupList) DeepCopyInto(out *PodGroupList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupList) DeepCopyObject added in v0.37.0 

func (in *PodGroupList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*PodGroupList) Marshal added in v0.37.0 

func (m *PodGroupList) Marshal() (dAtA []byte, err error)

func (*PodGroupList) MarshalTo added in v0.37.0 

func (m *PodGroupList) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupList) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupList) OpenAPIModelName added in v0.37.0 

func (in PodGroupList) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupList) Reset added in v0.37.0 

func (m *PodGroupList) Reset()

func (*PodGroupList) Size added in v0.37.0 

func (m *PodGroupList) Size() (n int)

func (*PodGroupList) String added in v0.37.0 

func (this *PodGroupList) String() string

func (PodGroupList) SwaggerDoc added in v0.37.0 

func (PodGroupList) SwaggerDoc() map[string]string

func (*PodGroupList) Unmarshal added in v0.37.0 

func (m *PodGroupList) Unmarshal(dAtA []byte) error

type PodGroupResourceClaim added in v0.37.0 

type PodGroupResourceClaim struct {
	// name uniquely identifies this resource claim inside the PodGroup.
	// This must be a DNS_LABEL.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-short-name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// resourceClaimName is the name of a ResourceClaim object in the same
	// namespace as this PodGroup. The ResourceClaim will be reserved for the
	// PodGroup instead of its individual pods.
	//
	// Exactly one of ResourceClaimName and ResourceClaimTemplateName must
	// be set.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	// +k8s:format=k8s-long-name
	ResourceClaimName *string `json:"resourceClaimName,omitempty" protobuf:"bytes,2,opt,name=resourceClaimName"`

	// resourceClaimTemplateName is the name of a ResourceClaimTemplate
	// object in the same namespace as this PodGroup.
	//
	// The template will be used to create a new ResourceClaim, which will
	// be bound to this PodGroup. When this PodGroup is deleted, the ResourceClaim
	// will also be deleted. The PodGroup name and resource name, along with a
	// generated component, will be used to form a unique name for the
	// ResourceClaim, which will be recorded in podgroup.status.resourceClaimStatuses.
	//
	// This field is immutable and no changes will be made to the
	// corresponding ResourceClaim by the control plane after creating the
	// ResourceClaim.
	//
	// Exactly one of ResourceClaimName and ResourceClaimTemplateName must
	// be set.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	// +k8s:format=k8s-long-name
	ResourceClaimTemplateName *string `json:"resourceClaimTemplateName,omitempty" protobuf:"bytes,3,opt,name=resourceClaimTemplateName"`
}

PodGroupResourceClaim references exactly one ResourceClaim, either directly or by naming a ResourceClaimTemplate which is then turned into a ResourceClaim for the PodGroup.

It adds a name to it that uniquely identifies the ResourceClaim inside the PodGroup. Pods that need access to the ResourceClaim define a matching reference in its own Spec.ResourceClaims. The Pod's claim must match all fields of the PodGroup's claim exactly.

func (*PodGroupResourceClaim) DeepCopy added in v0.37.0 

func (in *PodGroupResourceClaim) DeepCopy() *PodGroupResourceClaim

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupResourceClaim.

func (*PodGroupResourceClaim) DeepCopyInto added in v0.37.0 

func (in *PodGroupResourceClaim) DeepCopyInto(out *PodGroupResourceClaim)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupResourceClaim) Marshal added in v0.37.0 

func (m *PodGroupResourceClaim) Marshal() (dAtA []byte, err error)

func (*PodGroupResourceClaim) MarshalTo added in v0.37.0 

func (m *PodGroupResourceClaim) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupResourceClaim) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupResourceClaim) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupResourceClaim) OpenAPIModelName added in v0.37.0 

func (in PodGroupResourceClaim) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupResourceClaim) Reset added in v0.37.0 

func (m *PodGroupResourceClaim) Reset()

func (*PodGroupResourceClaim) Size added in v0.37.0 

func (m *PodGroupResourceClaim) Size() (n int)

func (*PodGroupResourceClaim) String added in v0.37.0 

func (this *PodGroupResourceClaim) String() string

func (PodGroupResourceClaim) SwaggerDoc added in v0.37.0 

func (PodGroupResourceClaim) SwaggerDoc() map[string]string

func (*PodGroupResourceClaim) Unmarshal added in v0.37.0 

func (m *PodGroupResourceClaim) Unmarshal(dAtA []byte) error

type PodGroupResourceClaimStatus added in v0.37.0 

type PodGroupResourceClaimStatus struct {
	// name uniquely identifies this resource claim inside the PodGroup. This
	// must match the name of an entry in podgroup.spec.resourceClaims, which
	// implies that the string must be a DNS_LABEL.
	//
	// +required
	Name string `json:"name" protobuf:"bytes,1,name=name"`

	// resourceClaimName is the name of the ResourceClaim that was generated for
	// the PodGroup in the namespace of the PodGroup. If this is unset, then
	// generating a ResourceClaim was not necessary. The
	// podgroup.spec.resourceClaims entry can be ignored in this case.
	//
	// +optional
	// +k8s:optional
	// +k8s:format=k8s-long-name
	ResourceClaimName *string `json:"resourceClaimName,omitempty" protobuf:"bytes,2,opt,name=resourceClaimName"`
}

PodGroupResourceClaimStatus is stored in the PodGroupStatus for each PodGroupResourceClaim which references a ResourceClaimTemplate. It stores the generated name for the corresponding ResourceClaim.

func (*PodGroupResourceClaimStatus) DeepCopy added in v0.37.0 

func (in *PodGroupResourceClaimStatus) DeepCopy() *PodGroupResourceClaimStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupResourceClaimStatus.

func (*PodGroupResourceClaimStatus) DeepCopyInto added in v0.37.0 

func (in *PodGroupResourceClaimStatus) DeepCopyInto(out *PodGroupResourceClaimStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupResourceClaimStatus) Marshal added in v0.37.0 

func (m *PodGroupResourceClaimStatus) Marshal() (dAtA []byte, err error)

func (*PodGroupResourceClaimStatus) MarshalTo added in v0.37.0 

func (m *PodGroupResourceClaimStatus) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupResourceClaimStatus) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupResourceClaimStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupResourceClaimStatus) OpenAPIModelName added in v0.37.0 

func (in PodGroupResourceClaimStatus) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupResourceClaimStatus) Reset added in v0.37.0 

func (m *PodGroupResourceClaimStatus) Reset()

func (*PodGroupResourceClaimStatus) Size added in v0.37.0 

func (m *PodGroupResourceClaimStatus) Size() (n int)

func (*PodGroupResourceClaimStatus) String added in v0.37.0 

func (this *PodGroupResourceClaimStatus) String() string

func (PodGroupResourceClaimStatus) SwaggerDoc added in v0.37.0 

func (PodGroupResourceClaimStatus) SwaggerDoc() map[string]string

func (*PodGroupResourceClaimStatus) Unmarshal added in v0.37.0 

func (m *PodGroupResourceClaimStatus) Unmarshal(dAtA []byte) error

type PodGroupSchedulingConstraints added in v0.37.0 

type PodGroupSchedulingConstraints struct {
	// topology defines the topology constraints for the pod group.
	// Currently only a single topology constraint can be specified. This may change in the future.
	//
	// +optional
	// +k8s:optional
	// +k8s:maxItems=1
	// +listType=atomic
	// +k8s:listType=atomic
	Topology []TopologyConstraint `json:"topology,omitempty" protobuf:"bytes,1,rep,name=topology"`
}

PodGroupSchedulingConstraints defines scheduling constraints (e.g. topology) for a PodGroup.

func (*PodGroupSchedulingConstraints) DeepCopy added in v0.37.0 

func (in *PodGroupSchedulingConstraints) DeepCopy() *PodGroupSchedulingConstraints

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupSchedulingConstraints.

func (*PodGroupSchedulingConstraints) DeepCopyInto added in v0.37.0 

func (in *PodGroupSchedulingConstraints) DeepCopyInto(out *PodGroupSchedulingConstraints)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupSchedulingConstraints) Marshal added in v0.37.0 

func (m *PodGroupSchedulingConstraints) Marshal() (dAtA []byte, err error)

func (*PodGroupSchedulingConstraints) MarshalTo added in v0.37.0 

func (m *PodGroupSchedulingConstraints) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupSchedulingConstraints) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupSchedulingConstraints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupSchedulingConstraints) OpenAPIModelName added in v0.37.0 

func (in PodGroupSchedulingConstraints) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupSchedulingConstraints) Reset added in v0.37.0 

func (m *PodGroupSchedulingConstraints) Reset()

func (*PodGroupSchedulingConstraints) Size added in v0.37.0 

func (m *PodGroupSchedulingConstraints) Size() (n int)

func (*PodGroupSchedulingConstraints) String added in v0.37.0 

func (this *PodGroupSchedulingConstraints) String() string

func (PodGroupSchedulingConstraints) SwaggerDoc added in v0.37.0 

func (PodGroupSchedulingConstraints) SwaggerDoc() map[string]string

func (*PodGroupSchedulingConstraints) Unmarshal added in v0.37.0 

func (m *PodGroupSchedulingConstraints) Unmarshal(dAtA []byte) error

type PodGroupSchedulingPolicy added in v0.37.0 

type PodGroupSchedulingPolicy struct {
	// basic specifies that the pods in this group should be scheduled using
	// standard Kubernetes scheduling behavior. Setting this field at group creation time
	// opts this group to basic scheduling; this field cannot be changed afterward.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	// +k8s:immutable
	Basic *BasicSchedulingPolicy `json:"basic,omitempty" protobuf:"bytes,1,opt,name=basic"`

	// gang specifies that the pods in this group should be scheduled using
	// all-or-nothing semantics. Setting this field at group creation time
	// opts this group to gang scheduling; this field cannot be set or unset afterward.
	// The minCount field within Gang scheduling policy remains mutable after group creation.
	//
	// +optional
	// +k8s:optional
	// +k8s:unionMember
	// +k8s:update=NoSet
	// +k8s:update=NoUnset
	Gang *GangSchedulingPolicy `json:"gang,omitempty" protobuf:"bytes,2,opt,name=gang"`
}

PodGroupSchedulingPolicy defines the scheduling configuration for a PodGroup. Exactly one policy must be set. The policy is chosen at creation time by setting either the Basic or Gang field. The PodGroup may not change policy after creation. Fields within chosen policy may be updated after creation when their individual fields allow it.

+union

func (*PodGroupSchedulingPolicy) DeepCopy added in v0.37.0 

func (in *PodGroupSchedulingPolicy) DeepCopy() *PodGroupSchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupSchedulingPolicy.

func (*PodGroupSchedulingPolicy) DeepCopyInto added in v0.37.0 

func (in *PodGroupSchedulingPolicy) DeepCopyInto(out *PodGroupSchedulingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupSchedulingPolicy) Marshal added in v0.37.0 

func (m *PodGroupSchedulingPolicy) Marshal() (dAtA []byte, err error)

func (*PodGroupSchedulingPolicy) MarshalTo added in v0.37.0 

func (m *PodGroupSchedulingPolicy) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupSchedulingPolicy) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupSchedulingPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupSchedulingPolicy) OpenAPIModelName added in v0.37.0 

func (in PodGroupSchedulingPolicy) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupSchedulingPolicy) Reset added in v0.37.0 

func (m *PodGroupSchedulingPolicy) Reset()

func (*PodGroupSchedulingPolicy) Size added in v0.37.0 

func (m *PodGroupSchedulingPolicy) Size() (n int)

func (*PodGroupSchedulingPolicy) String added in v0.37.0 

func (this *PodGroupSchedulingPolicy) String() string

func (PodGroupSchedulingPolicy) SwaggerDoc added in v0.37.0 

func (PodGroupSchedulingPolicy) SwaggerDoc() map[string]string

func (*PodGroupSchedulingPolicy) Unmarshal added in v0.37.0 

func (m *PodGroupSchedulingPolicy) Unmarshal(dAtA []byte) error

type PodGroupSpec added in v0.37.0 

type PodGroupSpec struct {
	// parentCompositePodGroupName contains the name of the parent composite pod group
	// within the same namespace as this pod group.
	// If it's nil, then this pod group is a root of a workload's hierarchy.
	// This field is used only when the CompositePodGroup feature gate is enabled.
	// This field is immutable.
	//
	// +featureGate=CompositePodGroup
	// +optional
	// +k8s:ifDisabled(CompositePodGroup)=+k8s:forbidden
	// +k8s:ifEnabled(CompositePodGroup)=+k8s:optional
	// +k8s:immutable
	// +k8s:format=k8s-long-name
	// +k8s:alpha(since: "1.37")=+k8s:dependentRequired("workloadRef")
	ParentCompositePodGroupName *string `json:"parentCompositePodGroupName,omitempty" protobuf:"bytes,1,opt,name=parentCompositePodGroupName"`

	// workloadRef references an optional PodGroup template within the Workload
	// object that was used to create the PodGroup.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	WorkloadRef *WorkloadReference `json:"workloadRef,omitempty" protobuf:"bytes,2,opt,name=workloadRef"`

	// schedulingPolicy defines the scheduling policy for this instance of the PodGroup.
	// Controllers are expected to fill this field by copying it from a PodGroupTemplate.
	//
	// +required
	SchedulingPolicy PodGroupSchedulingPolicy `json:"schedulingPolicy" protobuf:"bytes,3,opt,name=schedulingPolicy"`

	// schedulingConstraints defines optional scheduling constraints (e.g. topology) for this PodGroup.
	// Controllers are expected to fill this field by copying it from a PodGroupTemplate.
	// This field is immutable.
	// This field is only available when the TopologyAwareWorkloadScheduling feature gate is enabled.
	//
	// +featureGate=TopologyAwareWorkloadScheduling
	// +optional
	// +k8s:ifDisabled(TopologyAwareWorkloadScheduling)=+k8s:forbidden
	// +k8s:ifEnabled(TopologyAwareWorkloadScheduling)=+k8s:optional
	// +k8s:ifEnabled(TopologyAwareWorkloadScheduling)=+k8s:immutable
	SchedulingConstraints *PodGroupSchedulingConstraints `json:"schedulingConstraints,omitempty" protobuf:"bytes,4,opt,name=schedulingConstraints"`

	// resourceClaims defines which ResourceClaims may be shared among Pods in
	// the group. Pods consume the devices allocated to a PodGroup's claim by
	// defining a claim in its own Spec.ResourceClaims that matches the
	// PodGroup's claim exactly. The claim must have the same name and refer to
	// the same ResourceClaim or ResourceClaimTemplate.
	//
	// This is a beta-level field and requires that the
	// DRAWorkloadResourceClaims feature gate is enabled.
	//
	// This field is immutable.
	//
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge,retainKeys
	// +listType=map
	// +listMapKey=name
	// +k8s:optional
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=4
	// +k8s:immutable
	// +featureGate=DRAWorkloadResourceClaims
	ResourceClaims []PodGroupResourceClaim `` /* 128-byte string literal not displayed */

	// disruptionMode defines the mode in which a given PodGroup can be disrupted.
	// Controllers are expected to fill this field by copying it from a PodGroupTemplate.
	// One of Single, All. Defaults to Single if unset.
	// This field is immutable.
	//
	// +default={"single": {}}
	// +optional
	// +k8s:optional
	// +k8s:immutable
	DisruptionMode *DisruptionMode `json:"disruptionMode,omitempty" protobuf:"bytes,6,opt,name=disruptionMode"`

	// priorityClassName defines the priority that should be considered when scheduling this pod group.
	// Controllers are expected to fill this field by copying it from a PodGroupTemplate.
	// Otherwise, it is validated and resolved similarly to the PriorityClassName on PodGroupTemplate
	// (i.e. if no priority class is specified, admission control can set this to the global default
	// priority class if it exists. Otherwise, the pod group's priority will be zero).
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	// +k8s:format=k8s-long-name
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,7,opt,name=priorityClassName"`

	// priority is the value of priority of this pod group. Various system components
	// use this field to find the priority of the pod group. When Priority Admission
	// Controller is enabled, it prevents users from setting this field. The admission
	// controller populates this field from PriorityClassName.
	// The higher the value, the higher the priority.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	// +k8s:maximum=1000000000 # HighestUserDefinablePriority
	Priority *int32 `json:"priority,omitempty" protobuf:"varint,8,opt,name=priority"`

	// preemptionPolicy is the Policy for preempting pods/podgroups with lower priority.
	// One of Never, PreemptLowerPriority. Defaults to PreemptLowerPriority if unset.
	// When Priority Admission Controller is enabled, it populates this field from PriorityClassName,
	// and defaults to PreemptLowerPriority if value is unset in PriorityClass.
	// This field is immutable.
	// This field is available only when the PodGroupPreemptionPolicy feature gate is enabled.
	//
	// +featureGate=PodGroupPreemptionPolicy
	// +optional
	// +k8s:immutable
	// +k8s:ifDisabled("PodGroupPreemptionPolicy")=+k8s:forbidden
	// +k8s:ifEnabled("PodGroupPreemptionPolicy")=+k8s:optional
	PreemptionPolicy *PreemptionPolicy `json:"preemptionPolicy,omitempty" protobuf:"bytes,9,opt,name=preemptionPolicy"`
}

PodGroupSpec defines the desired state of a PodGroup.

func (*PodGroupSpec) DeepCopy added in v0.37.0 

func (in *PodGroupSpec) DeepCopy() *PodGroupSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupSpec.

func (*PodGroupSpec) DeepCopyInto added in v0.37.0 

func (in *PodGroupSpec) DeepCopyInto(out *PodGroupSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupSpec) Marshal added in v0.37.0 

func (m *PodGroupSpec) Marshal() (dAtA []byte, err error)

func (*PodGroupSpec) MarshalTo added in v0.37.0 

func (m *PodGroupSpec) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupSpec) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupSpec) OpenAPIModelName added in v0.37.0 

func (in PodGroupSpec) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupSpec) Reset added in v0.37.0 

func (m *PodGroupSpec) Reset()

func (*PodGroupSpec) Size added in v0.37.0 

func (m *PodGroupSpec) Size() (n int)

func (*PodGroupSpec) String added in v0.37.0 

func (this *PodGroupSpec) String() string

func (PodGroupSpec) SwaggerDoc added in v0.37.0 

func (PodGroupSpec) SwaggerDoc() map[string]string

func (*PodGroupSpec) Unmarshal added in v0.37.0 

func (m *PodGroupSpec) Unmarshal(dAtA []byte) error

type PodGroupStatus added in v0.37.0 

type PodGroupStatus struct {
	// conditions represent the latest observations of the PodGroup's state.
	//
	// Known condition types:
	// - "PodGroupInitiallyScheduled": Indicates whether the scheduling requirement has been satisfied.
	// Once this condition transitions to True, it serves as a terminal state and will never revert to False,
	// even if pods are subsequently evicted and group constraints are no longer met.
	// - "DisruptionTarget": Indicates whether the PodGroup is about to be terminated
	//   due to disruption such as preemption.
	//
	// Known reasons for the PodGroupInitiallyScheduled condition:
	// - "Unschedulable": The PodGroup cannot be scheduled due to resource constraints,
	//   affinity/anti-affinity rules, or insufficient capacity for the gang.
	// - "SchedulerError": The PodGroup cannot be scheduled due to some internal error
	//   that happened during scheduling, for example due to nodeAffinity parsing errors.
	//
	// Known reasons for the DisruptionTarget condition:
	// - "PreemptionByScheduler": The PodGroup was preempted by the scheduler to make room for
	//   higher-priority PodGroups or Pods.
	//
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +k8s:alpha(since: "1.37")=+k8s:optional
	// +k8s:alpha(since: "1.37")=+k8s:listType=map
	// +k8s:alpha(since: "1.37")=+k8s:listMapKey=type
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`

	// resourceClaimStatuses is status of resource claims.
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge,retainKeys
	// +listType=map
	// +listMapKey=name
	// +k8s:optional
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=4
	// +featureGate=DRAWorkloadResourceClaims
	ResourceClaimStatuses []PodGroupResourceClaimStatus `` /* 142-byte string literal not displayed */
}

PodGroupStatus represents information about the status of a pod group.

func (*PodGroupStatus) DeepCopy added in v0.37.0 

func (in *PodGroupStatus) DeepCopy() *PodGroupStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupStatus.

func (*PodGroupStatus) DeepCopyInto added in v0.37.0 

func (in *PodGroupStatus) DeepCopyInto(out *PodGroupStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupStatus) Marshal added in v0.37.0 

func (m *PodGroupStatus) Marshal() (dAtA []byte, err error)

func (*PodGroupStatus) MarshalTo added in v0.37.0 

func (m *PodGroupStatus) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupStatus) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupStatus) OpenAPIModelName added in v0.37.0 

func (in PodGroupStatus) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupStatus) Reset added in v0.37.0 

func (m *PodGroupStatus) Reset()

func (*PodGroupStatus) Size added in v0.37.0 

func (m *PodGroupStatus) Size() (n int)

func (*PodGroupStatus) String added in v0.37.0 

func (this *PodGroupStatus) String() string

func (PodGroupStatus) SwaggerDoc added in v0.37.0 

func (PodGroupStatus) SwaggerDoc() map[string]string

func (*PodGroupStatus) Unmarshal added in v0.37.0 

func (m *PodGroupStatus) Unmarshal(dAtA []byte) error

type PodGroupTemplate added in v0.37.0 

type PodGroupTemplate struct {
	// name is a unique identifier for the PodGroupTemplate within the Workload.
	// It must be a DNS label. This field is immutable.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-short-name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// schedulingPolicy defines the scheduling policy for this PodGroupTemplate.
	//
	// +required
	SchedulingPolicy PodGroupSchedulingPolicy `json:"schedulingPolicy" protobuf:"bytes,2,opt,name=schedulingPolicy"`

	// schedulingConstraints defines optional scheduling constraints (e.g. topology) for this PodGroupTemplate.
	// This field is only available when the TopologyAwareWorkloadScheduling feature gate is enabled.
	// This field is immutable.
	//
	// +featureGate=TopologyAwareWorkloadScheduling
	// +optional
	// +k8s:ifDisabled(TopologyAwareWorkloadScheduling)=+k8s:forbidden
	// +k8s:ifEnabled(TopologyAwareWorkloadScheduling)=+k8s:optional
	// +k8s:immutable
	SchedulingConstraints *PodGroupSchedulingConstraints `json:"schedulingConstraints" protobuf:"bytes,3,opt,name=schedulingConstraints"`

	// resourceClaims defines which ResourceClaims may be shared among Pods in
	// the group. Pods consume the devices allocated to a PodGroup's claim by
	// defining a claim in its own Spec.ResourceClaims that matches the
	// PodGroup's claim exactly. The claim must have the same name and refer to
	// the same ResourceClaim or ResourceClaimTemplate.
	//
	// This is a beta-level field and requires that the
	// DRAWorkloadResourceClaims feature gate is enabled.
	//
	// This field is immutable.
	//
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge,retainKeys
	// +listType=map
	// +listMapKey=name
	// +k8s:optional
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=4
	// +featureGate=DRAWorkloadResourceClaims
	// +k8s:immutable
	ResourceClaims []PodGroupResourceClaim `` /* 128-byte string literal not displayed */

	// disruptionMode defines the mode in which a given PodGroup can be disrupted.
	// One of Single, All.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	DisruptionMode *DisruptionMode `json:"disruptionMode,omitempty" protobuf:"bytes,5,opt,name=disruptionMode"`

	// priorityClassName indicates the priority that should be considered when scheduling
	// a pod group created from this template.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:format=k8s-long-name
	// +k8s:immutable
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,6,opt,name=priorityClassName"`

	// priority is the value of priority of pod groups created from this template. Various
	// system components use this field to find the priority of the pod group.
	// The higher the value, the higher the priority.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:maximum=1000000000 # HighestUserDefinablePriority
	// +k8s:immutable
	Priority *int32 `json:"priority,omitempty" protobuf:"varint,7,opt,name=priority"`

	// preemptionPolicy is the Policy for preempting pods/podgroups with lower priority.
	// One of Never, PreemptLowerPriority.
	// This field is immutable.
	// This field is available only when the PodGroupPreemptionPolicy feature gate is enabled.
	//
	// +featureGate=PodGroupPreemptionPolicy
	// +optional
	// +k8s:immutable
	// +k8s:ifDisabled("PodGroupPreemptionPolicy")=+k8s:forbidden
	// +k8s:ifEnabled("PodGroupPreemptionPolicy")=+k8s:optional
	PreemptionPolicy *PreemptionPolicy `json:"preemptionPolicy,omitempty" protobuf:"bytes,8,opt,name=preemptionPolicy"`
}

PodGroupTemplate represents a template for a set of pods with a scheduling policy.

func (*PodGroupTemplate) DeepCopy added in v0.37.0 

func (in *PodGroupTemplate) DeepCopy() *PodGroupTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGroupTemplate.

func (*PodGroupTemplate) DeepCopyInto added in v0.37.0 

func (in *PodGroupTemplate) DeepCopyInto(out *PodGroupTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGroupTemplate) Marshal added in v0.37.0 

func (m *PodGroupTemplate) Marshal() (dAtA []byte, err error)

func (*PodGroupTemplate) MarshalTo added in v0.37.0 

func (m *PodGroupTemplate) MarshalTo(dAtA []byte) (int, error)

func (*PodGroupTemplate) MarshalToSizedBuffer added in v0.37.0 

func (m *PodGroupTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PodGroupTemplate) OpenAPIModelName added in v0.37.0 

func (in PodGroupTemplate) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PodGroupTemplate) Reset added in v0.37.0 

func (m *PodGroupTemplate) Reset()

func (*PodGroupTemplate) Size added in v0.37.0 

func (m *PodGroupTemplate) Size() (n int)

func (*PodGroupTemplate) String added in v0.37.0 

func (this *PodGroupTemplate) String() string

func (PodGroupTemplate) SwaggerDoc added in v0.37.0 

func (PodGroupTemplate) SwaggerDoc() map[string]string

func (*PodGroupTemplate) Unmarshal added in v0.37.0 

func (m *PodGroupTemplate) Unmarshal(dAtA []byte) error

type PreemptionPolicy added in v0.37.0 

type PreemptionPolicy string

PreemptionPolicy describes a policy for if/when to preempt a pod. +enum +k8s:enum 

const (
	// PreemptLowerPriority means that pod can preempt other pods with lower priority.
	PreemptLowerPriority PreemptionPolicy = "PreemptLowerPriority"
	// PreemptNever means that pod never preempts other pods with lower priority.
	PreemptNever PreemptionPolicy = "Never"
)

type PriorityClass 

type PriorityClass struct {
	metav1.TypeMeta `json:""`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// value represents the integer value of this priority class. This is the actual priority that pods
	// receive when they have the name of this class in their pod spec.
	// +optional
	Value int32 `json:"value" protobuf:"bytes,2,opt,name=value"`

	// globalDefault specifies whether this PriorityClass should be considered as
	// the default priority for pods that do not have any priority class.
	// Only one PriorityClass can be marked as `globalDefault`. However, if more than
	// one PriorityClasses exists with their `globalDefault` field set to true,
	// the smallest value of such global default PriorityClasses will be used as the default priority.
	// +optional
	GlobalDefault bool `json:"globalDefault,omitempty" protobuf:"bytes,3,opt,name=globalDefault"`

	// description is an arbitrary string that usually provides guidelines on
	// when this priority class should be used.
	// +optional
	Description string `json:"description,omitempty" protobuf:"bytes,4,opt,name=description"`

	// preemptionPolicy is the Policy for preempting pods with lower priority.
	// One of Never, PreemptLowerPriority.
	// Defaults to PreemptLowerPriority if unset.
	// +optional
	PreemptionPolicy *apiv1.PreemptionPolicy `json:"preemptionPolicy,omitempty" protobuf:"bytes,5,opt,name=preemptionPolicy"`
}

DEPRECATED - This group version of PriorityClass is deprecated by scheduling.k8s.io/v1/PriorityClass. PriorityClass defines mapping from a priority class name to the priority integer value. The value can be any valid integer.

func (*PriorityClass) APILifecycleDeprecated added in v0.19.0 

func (in *PriorityClass) APILifecycleDeprecated() (major, minor int)

APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.

func (*PriorityClass) APILifecycleIntroduced added in v0.19.0 

func (in *PriorityClass) APILifecycleIntroduced() (major, minor int)

APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.

func (*PriorityClass) APILifecycleRemoved added in v0.19.0 

func (in *PriorityClass) APILifecycleRemoved() (major, minor int)

APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.

func (*PriorityClass) APILifecycleReplacement added in v0.19.0 

func (in *PriorityClass) APILifecycleReplacement() schema.GroupVersionKind

APILifecycleReplacement is an autogenerated function, returning the group, version, and kind that should be used instead of this deprecated type. It is controlled by "k8s:prerelease-lifecycle-gen:replacement=<group>,<version>,<kind>" tags in types.go.

func (*PriorityClass) DeepCopy 

func (in *PriorityClass) DeepCopy() *PriorityClass

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PriorityClass.

func (*PriorityClass) DeepCopyInto 

func (in *PriorityClass) DeepCopyInto(out *PriorityClass)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PriorityClass) DeepCopyObject 

func (in *PriorityClass) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*PriorityClass) Marshal 

func (m *PriorityClass) Marshal() (dAtA []byte, err error)

func (*PriorityClass) MarshalTo 

func (m *PriorityClass) MarshalTo(dAtA []byte) (int, error)

func (*PriorityClass) MarshalToSizedBuffer added in v0.16.4 

func (m *PriorityClass) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PriorityClass) OpenAPIModelName added in v0.35.0 

func (in PriorityClass) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PriorityClass) Reset 

func (m *PriorityClass) Reset()

func (*PriorityClass) Size 

func (m *PriorityClass) Size() (n int)

func (*PriorityClass) String 

func (this *PriorityClass) String() string

func (PriorityClass) SwaggerDoc 

func (PriorityClass) SwaggerDoc() map[string]string

func (*PriorityClass) Unmarshal 

func (m *PriorityClass) Unmarshal(dAtA []byte) error

type PriorityClassList 

type PriorityClassList struct {
	metav1.TypeMeta `json:""`
	// Standard list metadata
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of PriorityClasses
	Items []PriorityClass `json:"items" protobuf:"bytes,2,rep,name=items"`
}

PriorityClassList is a collection of priority classes.

func (*PriorityClassList) APILifecycleDeprecated added in v0.19.0 

func (in *PriorityClassList) APILifecycleDeprecated() (major, minor int)

APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.

func (*PriorityClassList) APILifecycleIntroduced added in v0.19.0 

func (in *PriorityClassList) APILifecycleIntroduced() (major, minor int)

APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.

func (*PriorityClassList) APILifecycleRemoved added in v0.19.0 

func (in *PriorityClassList) APILifecycleRemoved() (major, minor int)

APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.

func (*PriorityClassList) APILifecycleReplacement added in v0.19.0 

func (in *PriorityClassList) APILifecycleReplacement() schema.GroupVersionKind

APILifecycleReplacement is an autogenerated function, returning the group, version, and kind that should be used instead of this deprecated type. It is controlled by "k8s:prerelease-lifecycle-gen:replacement=<group>,<version>,<kind>" tags in types.go.

func (*PriorityClassList) DeepCopy 

func (in *PriorityClassList) DeepCopy() *PriorityClassList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PriorityClassList.

func (*PriorityClassList) DeepCopyInto 

func (in *PriorityClassList) DeepCopyInto(out *PriorityClassList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PriorityClassList) DeepCopyObject 

func (in *PriorityClassList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*PriorityClassList) Marshal 

func (m *PriorityClassList) Marshal() (dAtA []byte, err error)

func (*PriorityClassList) MarshalTo 

func (m *PriorityClassList) MarshalTo(dAtA []byte) (int, error)

func (*PriorityClassList) MarshalToSizedBuffer added in v0.16.4 

func (m *PriorityClassList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (PriorityClassList) OpenAPIModelName added in v0.35.0 

func (in PriorityClassList) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*PriorityClassList) Reset 

func (m *PriorityClassList) Reset()

func (*PriorityClassList) Size 

func (m *PriorityClassList) Size() (n int)

func (*PriorityClassList) String 

func (this *PriorityClassList) String() string

func (PriorityClassList) SwaggerDoc 

func (PriorityClassList) SwaggerDoc() map[string]string

func (*PriorityClassList) Unmarshal 

func (m *PriorityClassList) Unmarshal(dAtA []byte) error

type SingleCompositeDisruptionMode added in v0.37.0 

type SingleCompositeDisruptionMode struct {
}

SingleCompositeDisruptionMode means that individual children of a CompositePodGroup can be disrupted or preempted independently.

func (*SingleCompositeDisruptionMode) DeepCopy added in v0.37.0 

func (in *SingleCompositeDisruptionMode) DeepCopy() *SingleCompositeDisruptionMode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SingleCompositeDisruptionMode.

func (*SingleCompositeDisruptionMode) DeepCopyInto added in v0.37.0 

func (in *SingleCompositeDisruptionMode) DeepCopyInto(out *SingleCompositeDisruptionMode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SingleCompositeDisruptionMode) Marshal added in v0.37.0 

func (m *SingleCompositeDisruptionMode) Marshal() (dAtA []byte, err error)

func (*SingleCompositeDisruptionMode) MarshalTo added in v0.37.0 

func (m *SingleCompositeDisruptionMode) MarshalTo(dAtA []byte) (int, error)

func (*SingleCompositeDisruptionMode) MarshalToSizedBuffer added in v0.37.0 

func (m *SingleCompositeDisruptionMode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (SingleCompositeDisruptionMode) OpenAPIModelName added in v0.37.0 

func (in SingleCompositeDisruptionMode) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*SingleCompositeDisruptionMode) Reset added in v0.37.0 

func (m *SingleCompositeDisruptionMode) Reset()

func (*SingleCompositeDisruptionMode) Size added in v0.37.0 

func (m *SingleCompositeDisruptionMode) Size() (n int)

func (*SingleCompositeDisruptionMode) String added in v0.37.0 

func (this *SingleCompositeDisruptionMode) String() string

func (SingleCompositeDisruptionMode) SwaggerDoc added in v0.37.0 

func (SingleCompositeDisruptionMode) SwaggerDoc() map[string]string

func (*SingleCompositeDisruptionMode) Unmarshal added in v0.37.0 

func (m *SingleCompositeDisruptionMode) Unmarshal(dAtA []byte) error

type SingleDisruptionMode added in v0.37.0 

type SingleDisruptionMode struct {
}

SingleDisruptionMode specifies that children can be disrupted independently.

func (*SingleDisruptionMode) DeepCopy added in v0.37.0 

func (in *SingleDisruptionMode) DeepCopy() *SingleDisruptionMode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SingleDisruptionMode.

func (*SingleDisruptionMode) DeepCopyInto added in v0.37.0 

func (in *SingleDisruptionMode) DeepCopyInto(out *SingleDisruptionMode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SingleDisruptionMode) Marshal added in v0.37.0 

func (m *SingleDisruptionMode) Marshal() (dAtA []byte, err error)

func (*SingleDisruptionMode) MarshalTo added in v0.37.0 

func (m *SingleDisruptionMode) MarshalTo(dAtA []byte) (int, error)

func (*SingleDisruptionMode) MarshalToSizedBuffer added in v0.37.0 

func (m *SingleDisruptionMode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (SingleDisruptionMode) OpenAPIModelName added in v0.37.0 

func (in SingleDisruptionMode) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*SingleDisruptionMode) Reset added in v0.37.0 

func (m *SingleDisruptionMode) Reset()

func (*SingleDisruptionMode) Size added in v0.37.0 

func (m *SingleDisruptionMode) Size() (n int)

func (*SingleDisruptionMode) String added in v0.37.0 

func (this *SingleDisruptionMode) String() string

func (SingleDisruptionMode) SwaggerDoc added in v0.37.0 

func (SingleDisruptionMode) SwaggerDoc() map[string]string

func (*SingleDisruptionMode) Unmarshal added in v0.37.0 

func (m *SingleDisruptionMode) Unmarshal(dAtA []byte) error

type TopologyConstraint added in v0.37.0 

type TopologyConstraint struct {
	// key specifies the key of the node label representing the topology domain.
	// All pods within the PodGroup must be colocated within the same domain instance.
	// Different PodGroups can land on different domain instances even if they derive from the same PodGroupTemplate.
	// Examples: "topology.kubernetes.io/rack"
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-label-key
	Key string `json:"key" protobuf:"bytes,1,opt,name=key"`
}

TopologyConstraint defines a topology constraint for a PodGroup.

func (*TopologyConstraint) DeepCopy added in v0.37.0 

func (in *TopologyConstraint) DeepCopy() *TopologyConstraint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopologyConstraint.

func (*TopologyConstraint) DeepCopyInto added in v0.37.0 

func (in *TopologyConstraint) DeepCopyInto(out *TopologyConstraint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopologyConstraint) Marshal added in v0.37.0 

func (m *TopologyConstraint) Marshal() (dAtA []byte, err error)

func (*TopologyConstraint) MarshalTo added in v0.37.0 

func (m *TopologyConstraint) MarshalTo(dAtA []byte) (int, error)

func (*TopologyConstraint) MarshalToSizedBuffer added in v0.37.0 

func (m *TopologyConstraint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (TopologyConstraint) OpenAPIModelName added in v0.37.0 

func (in TopologyConstraint) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*TopologyConstraint) Reset added in v0.37.0 

func (m *TopologyConstraint) Reset()

func (*TopologyConstraint) Size added in v0.37.0 

func (m *TopologyConstraint) Size() (n int)

func (*TopologyConstraint) String added in v0.37.0 

func (this *TopologyConstraint) String() string

func (TopologyConstraint) SwaggerDoc added in v0.37.0 

func (TopologyConstraint) SwaggerDoc() map[string]string

func (*TopologyConstraint) Unmarshal added in v0.37.0 

func (m *TopologyConstraint) Unmarshal(dAtA []byte) error

type TypedLocalObjectReference added in v0.37.0 

type TypedLocalObjectReference struct {
	// apiGroup is the group for the resource being referenced.
	// If apiGroup is empty, the specified Kind must be in the core API group.
	// For any other third-party types, setting apiGroup is required.
	// It must be a DNS subdomain.
	//
	// +optional
	// +k8s:optional
	// +k8s:format=k8s-long-name
	APIGroup string `json:"apiGroup,omitempty" protobuf:"bytes,1,opt,name=apiGroup"`
	// kind is the type of resource being referenced.
	// It must be a path segment name.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-path-segment-name
	Kind string `json:"kind" protobuf:"bytes,2,opt,name=kind"`
	// name is the name of resource being referenced.
	// It must be a path segment name.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-path-segment-name
	Name string `json:"name" protobuf:"bytes,3,opt,name=name"`
}

TypedLocalObjectReference allows to reference typed object inside the same namespace.

func (*TypedLocalObjectReference) DeepCopy added in v0.37.0 

func (in *TypedLocalObjectReference) DeepCopy() *TypedLocalObjectReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TypedLocalObjectReference.

func (*TypedLocalObjectReference) DeepCopyInto added in v0.37.0 

func (in *TypedLocalObjectReference) DeepCopyInto(out *TypedLocalObjectReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TypedLocalObjectReference) Marshal added in v0.37.0 

func (m *TypedLocalObjectReference) Marshal() (dAtA []byte, err error)

func (*TypedLocalObjectReference) MarshalTo added in v0.37.0 

func (m *TypedLocalObjectReference) MarshalTo(dAtA []byte) (int, error)

func (*TypedLocalObjectReference) MarshalToSizedBuffer added in v0.37.0 

func (m *TypedLocalObjectReference) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (TypedLocalObjectReference) OpenAPIModelName added in v0.37.0 

func (in TypedLocalObjectReference) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*TypedLocalObjectReference) Reset added in v0.37.0 

func (m *TypedLocalObjectReference) Reset()

func (*TypedLocalObjectReference) Size added in v0.37.0 

func (m *TypedLocalObjectReference) Size() (n int)

func (*TypedLocalObjectReference) String added in v0.37.0 

func (this *TypedLocalObjectReference) String() string

func (TypedLocalObjectReference) SwaggerDoc added in v0.37.0 

func (TypedLocalObjectReference) SwaggerDoc() map[string]string

func (*TypedLocalObjectReference) Unmarshal added in v0.37.0 

func (m *TypedLocalObjectReference) Unmarshal(dAtA []byte) error

type Workload added in v0.37.0 

type Workload struct {
	metav1.TypeMeta `json:""`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	//
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec defines the desired behavior of a Workload.
	//
	// +required
	Spec WorkloadSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

Workload allows for expressing scheduling constraints that should be used when managing the lifecycle of workloads from the scheduling perspective, including scheduling, preemption, eviction and other phases. Workload API enablement is toggled by the GenericWorkload feature gate.

func (*Workload) APILifecycleDeprecated added in v0.37.0 

func (in *Workload) APILifecycleDeprecated() (major, minor int)

APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.

func (*Workload) APILifecycleIntroduced added in v0.37.0 

func (in *Workload) APILifecycleIntroduced() (major, minor int)

APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.

func (*Workload) APILifecycleRemoved added in v0.37.0 

func (in *Workload) APILifecycleRemoved() (major, minor int)

APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.

func (*Workload) DeepCopy added in v0.37.0 

func (in *Workload) DeepCopy() *Workload

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workload.

func (*Workload) DeepCopyInto added in v0.37.0 

func (in *Workload) DeepCopyInto(out *Workload)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Workload) DeepCopyObject added in v0.37.0 

func (in *Workload) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Workload) Marshal added in v0.37.0 

func (m *Workload) Marshal() (dAtA []byte, err error)

func (*Workload) MarshalTo added in v0.37.0 

func (m *Workload) MarshalTo(dAtA []byte) (int, error)

func (*Workload) MarshalToSizedBuffer added in v0.37.0 

func (m *Workload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (Workload) OpenAPIModelName added in v0.37.0 

func (in Workload) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*Workload) Reset added in v0.37.0 

func (m *Workload) Reset()

func (*Workload) Size added in v0.37.0 

func (m *Workload) Size() (n int)

func (*Workload) String added in v0.37.0 

func (this *Workload) String() string

func (Workload) SwaggerDoc added in v0.37.0 

func (Workload) SwaggerDoc() map[string]string

func (*Workload) Unmarshal added in v0.37.0 

func (m *Workload) Unmarshal(dAtA []byte) error

type WorkloadList added in v0.37.0 

type WorkloadList struct {
	metav1.TypeMeta `json:""`
	// metadata is the standard list metadata.
	//
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of Workloads.
	Items []Workload `json:"items" protobuf:"bytes,2,rep,name=items"`
}

WorkloadList contains a list of Workload resources.

func (*WorkloadList) APILifecycleDeprecated added in v0.37.0 

func (in *WorkloadList) APILifecycleDeprecated() (major, minor int)

APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.

func (*WorkloadList) APILifecycleIntroduced added in v0.37.0 

func (in *WorkloadList) APILifecycleIntroduced() (major, minor int)

APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.

func (*WorkloadList) APILifecycleRemoved added in v0.37.0 

func (in *WorkloadList) APILifecycleRemoved() (major, minor int)

APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.

func (*WorkloadList) DeepCopy added in v0.37.0 

func (in *WorkloadList) DeepCopy() *WorkloadList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkloadList.

func (*WorkloadList) DeepCopyInto added in v0.37.0 

func (in *WorkloadList) DeepCopyInto(out *WorkloadList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkloadList) DeepCopyObject added in v0.37.0 

func (in *WorkloadList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*WorkloadList) Marshal added in v0.37.0 

func (m *WorkloadList) Marshal() (dAtA []byte, err error)

func (*WorkloadList) MarshalTo added in v0.37.0 

func (m *WorkloadList) MarshalTo(dAtA []byte) (int, error)

func (*WorkloadList) MarshalToSizedBuffer added in v0.37.0 

func (m *WorkloadList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (WorkloadList) OpenAPIModelName added in v0.37.0 

func (in WorkloadList) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*WorkloadList) Reset added in v0.37.0 

func (m *WorkloadList) Reset()

func (*WorkloadList) Size added in v0.37.0 

func (m *WorkloadList) Size() (n int)

func (*WorkloadList) String added in v0.37.0 

func (this *WorkloadList) String() string

func (WorkloadList) SwaggerDoc added in v0.37.0 

func (WorkloadList) SwaggerDoc() map[string]string

func (*WorkloadList) Unmarshal added in v0.37.0 

func (m *WorkloadList) Unmarshal(dAtA []byte) error

type WorkloadReference added in v0.37.0 

type WorkloadReference struct {
	// workloadName is the name of the Workload object that contains a template
	// that was used when creating a pod group. It must
	// be a DNS name.
	// This field is required.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-long-name
	WorkloadName string `json:"workloadName" protobuf:"bytes,1,opt,name=workloadName"`

	// templateName is the name of a template within the Workload object that
	// was used to create a pod group. It must be a DNS label.
	// This field is required.
	//
	// +required
	// +k8s:required
	// +k8s:format=k8s-short-name
	TemplateName string `json:"templateName" protobuf:"bytes,2,opt,name=templateName"`
}

WorkloadReference references the Workload object together with the template that was used to create a particular PodGroup.

func (*WorkloadReference) DeepCopy added in v0.37.0 

func (in *WorkloadReference) DeepCopy() *WorkloadReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkloadReference.

func (*WorkloadReference) DeepCopyInto added in v0.37.0 

func (in *WorkloadReference) DeepCopyInto(out *WorkloadReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkloadReference) Marshal added in v0.37.0 

func (m *WorkloadReference) Marshal() (dAtA []byte, err error)

func (*WorkloadReference) MarshalTo added in v0.37.0 

func (m *WorkloadReference) MarshalTo(dAtA []byte) (int, error)

func (*WorkloadReference) MarshalToSizedBuffer added in v0.37.0 

func (m *WorkloadReference) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (WorkloadReference) OpenAPIModelName added in v0.37.0 

func (in WorkloadReference) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*WorkloadReference) Reset added in v0.37.0 

func (m *WorkloadReference) Reset()

func (*WorkloadReference) Size added in v0.37.0 

func (m *WorkloadReference) Size() (n int)

func (*WorkloadReference) String added in v0.37.0 

func (this *WorkloadReference) String() string

func (WorkloadReference) SwaggerDoc added in v0.37.0 

func (WorkloadReference) SwaggerDoc() map[string]string

func (*WorkloadReference) Unmarshal added in v0.37.0 

func (m *WorkloadReference) Unmarshal(dAtA []byte) error

type WorkloadSpec added in v0.37.0 

type WorkloadSpec struct {
	// controllerRef is an optional reference to the controlling object, such as a
	// Deployment or Job. This field is intended for use by tools like CLIs
	// to provide a link back to the original workload definition.
	// This field is immutable.
	//
	// +optional
	// +k8s:optional
	// +k8s:immutable
	ControllerRef *TypedLocalObjectReference `json:"controllerRef,omitempty" protobuf:"bytes,1,opt,name=controllerRef"`

	// podGroupTemplates is the list of templates that make up the Workload.
	// The maximum number of templates is 8. Templates cannot be added or removed after the workload is created.
	// Existing templates may still be updated where their individual fields allow it.
	// Exactly one of CompositePodGroupTemplates and PodGroupTemplates must be set.
	//
	// +optional
	// +listType=map
	// +listMapKey=name
	// +k8s:optional
	// +k8s:unionMember
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=8
	// +k8s:update=NoAddItem
	// +k8s:update=NoRemoveItem
	PodGroupTemplates []PodGroupTemplate `json:"podGroupTemplates" protobuf:"bytes,2,rep,name=podGroupTemplates"`

	// compositePodGroupTemplates is the list of CompositePodGroup templates that make up the Workload.
	// The maximum number of templates is 8. This field is immutable.
	// Exactly one of CompositePodGroupTemplates and PodGroupTemplates must be set.
	//
	// This field is used only when the CompositePodGroup feature gate is enabled.
	//
	// +featureGate=CompositePodGroup
	// +optional
	// +listType=map
	// +listMapKey=name
	// +k8s:ifDisabled("CompositePodGroup")=+k8s:forbidden
	// +k8s:ifEnabled("CompositePodGroup")=+k8s:optional
	// +k8s:unionMember
	// +k8s:listType=map
	// +k8s:listMapKey=name
	// +k8s:maxItems=8
	// +k8s:update=NoAddItem
	// +k8s:update=NoRemoveItem
	CompositePodGroupTemplates []CompositePodGroupTemplate `json:"compositePodGroupTemplates,omitempty" protobuf:"bytes,3,rep,name=compositePodGroupTemplates"`
}

WorkloadSpec defines the desired state of a Workload.

func (*WorkloadSpec) DeepCopy added in v0.37.0 

func (in *WorkloadSpec) DeepCopy() *WorkloadSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkloadSpec.

func (*WorkloadSpec) DeepCopyInto added in v0.37.0 

func (in *WorkloadSpec) DeepCopyInto(out *WorkloadSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkloadSpec) Marshal added in v0.37.0 

func (m *WorkloadSpec) Marshal() (dAtA []byte, err error)

func (*WorkloadSpec) MarshalTo added in v0.37.0 

func (m *WorkloadSpec) MarshalTo(dAtA []byte) (int, error)

func (*WorkloadSpec) MarshalToSizedBuffer added in v0.37.0 

func (m *WorkloadSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (WorkloadSpec) OpenAPIModelName added in v0.37.0 

func (in WorkloadSpec) OpenAPIModelName() string

OpenAPIModelName returns the OpenAPI model name for this type.

func (*WorkloadSpec) Reset added in v0.37.0 

func (m *WorkloadSpec) Reset()

func (*WorkloadSpec) Size added in v0.37.0 

func (m *WorkloadSpec) Size() (n int)

func (*WorkloadSpec) String added in v0.37.0 

func (this *WorkloadSpec) String() string

func (WorkloadSpec) SwaggerDoc added in v0.37.0 

func (WorkloadSpec) SwaggerDoc() map[string]string

func (*WorkloadSpec) Unmarshal added in v0.37.0 

func (m *WorkloadSpec) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.