Documentation ¶
Index ¶
- Variables
- func Convert_url_Values_To_v1alpha1_PendingWorkloadOptions(in *url.Values, out *PendingWorkloadOptions, s conversion.Scope) error
- func RegisterConversions(s *runtime.Scheme) error
- func RegisterDefaults(scheme *runtime.Scheme) error
- func Resource(resource string) schema.GroupResource
- func SetDefaults_PendingWorkloadOptions(obj *PendingWorkloadOptions)
- func SetObjectDefaults_PendingWorkloadOptions(in *PendingWorkloadOptions)
- type ClusterQueue
- type ClusterQueueList
- type LocalQueue
- type LocalQueueList
- type PendingWorkload
- type PendingWorkloadOptions
- type PendingWorkloadsSummary
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects. GroupVersion = schema.GroupVersion{Group: "visibility.kueue.x-k8s.io", Version: "v1alpha1"} // SchemeGroupVersion is alias to GroupVersion for client-go libraries. // It is required by pkg/client/informers/externalversions/... SchemeGroupVersion = GroupVersion // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func Convert_url_Values_To_v1alpha1_PendingWorkloadOptions ¶
func Convert_url_Values_To_v1alpha1_PendingWorkloadOptions(in *url.Values, out *PendingWorkloadOptions, s conversion.Scope) error
Convert_url_Values_To_v1alpha1_PendingWorkloadOptions is an autogenerated conversion function.
func RegisterConversions ¶
RegisterConversions adds conversion functions to the given scheme. Public to allow building arbitrary schemes.
func RegisterDefaults ¶
RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource is required by pkg/client/listers/...
func SetDefaults_PendingWorkloadOptions ¶
func SetDefaults_PendingWorkloadOptions(obj *PendingWorkloadOptions)
func SetObjectDefaults_PendingWorkloadOptions ¶
func SetObjectDefaults_PendingWorkloadOptions(in *PendingWorkloadOptions)
Types ¶
type ClusterQueue ¶
type ClusterQueue struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Summary PendingWorkloadsSummary `json:"pendingWorkloadsSummary"` }
+genclient +kubebuilder:object:root=true +k8s:openapi-gen=true +genclient:nonNamespaced +genclient:method=GetPendingWorkloadsSummary,verb=get,subresource=pendingworkloads,result=sigs.k8s.io/kueue/apis/visibility/v1alpha1.PendingWorkloadsSummary
func (*ClusterQueue) DeepCopy ¶
func (in *ClusterQueue) DeepCopy() *ClusterQueue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterQueue.
func (*ClusterQueue) DeepCopyInto ¶
func (in *ClusterQueue) DeepCopyInto(out *ClusterQueue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterQueue) DeepCopyObject ¶
func (in *ClusterQueue) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterQueueList ¶
type ClusterQueueList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []ClusterQueue `json:"items"` }
+kubebuilder:object:root=true
func (*ClusterQueueList) DeepCopy ¶
func (in *ClusterQueueList) DeepCopy() *ClusterQueueList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterQueueList.
func (*ClusterQueueList) DeepCopyInto ¶
func (in *ClusterQueueList) DeepCopyInto(out *ClusterQueueList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterQueueList) DeepCopyObject ¶
func (in *ClusterQueueList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type LocalQueue ¶
type LocalQueue struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Summary PendingWorkloadsSummary `json:"pendingWorkloadsSummary"` }
+genclient +kubebuilder:object:root=true +k8s:openapi-gen=true +genclient:method=GetPendingWorkloadsSummary,verb=get,subresource=pendingworkloads,result=sigs.k8s.io/kueue/apis/visibility/v1alpha1.PendingWorkloadsSummary
func (*LocalQueue) DeepCopy ¶
func (in *LocalQueue) DeepCopy() *LocalQueue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocalQueue.
func (*LocalQueue) DeepCopyInto ¶
func (in *LocalQueue) DeepCopyInto(out *LocalQueue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LocalQueue) DeepCopyObject ¶
func (in *LocalQueue) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type LocalQueueList ¶
type LocalQueueList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []LocalQueue `json:"items"` }
+kubebuilder:object:root=true
func (*LocalQueueList) DeepCopy ¶
func (in *LocalQueueList) DeepCopy() *LocalQueueList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocalQueueList.
func (*LocalQueueList) DeepCopyInto ¶
func (in *LocalQueueList) DeepCopyInto(out *LocalQueueList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LocalQueueList) DeepCopyObject ¶
func (in *LocalQueueList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PendingWorkload ¶
type PendingWorkload struct { metav1.ObjectMeta `json:"metadata,omitempty"` // Priority indicates the workload's priority Priority int32 `json:"priority"` // LocalQueueName indicates the name of the LocalQueue the workload is submitted to LocalQueueName string `json:"localQueueName"` // PositionInClusterQueue indicates the workload's position in the ClusterQueue, starting from 0 PositionInClusterQueue int32 `json:"positionInClusterQueue"` // PositionInLocalQueue indicates the workload's position in the LocalQueue, starting from 0 PositionInLocalQueue int32 `json:"positionInLocalQueue"` }
PendingWorkload is a user-facing representation of a pending workload that summarizes the relevant information for position in the cluster queue.
func (*PendingWorkload) DeepCopy ¶
func (in *PendingWorkload) DeepCopy() *PendingWorkload
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PendingWorkload.
func (*PendingWorkload) DeepCopyInto ¶
func (in *PendingWorkload) DeepCopyInto(out *PendingWorkload)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PendingWorkloadOptions ¶
type PendingWorkloadOptions struct { metav1.TypeMeta `json:",inline"` // Offset indicates position of the first pending workload that should be fetched, starting from 0. 0 by default Offset int64 `json:"offset"` // Limit indicates max number of pending workloads that should be fetched. 1000 by default Limit int64 `json:"limit,omitempty"` }
PendingWorkloadOptions are query params used in the visibility queries
func (*PendingWorkloadOptions) DeepCopy ¶
func (in *PendingWorkloadOptions) DeepCopy() *PendingWorkloadOptions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PendingWorkloadOptions.
func (*PendingWorkloadOptions) DeepCopyInto ¶
func (in *PendingWorkloadOptions) DeepCopyInto(out *PendingWorkloadOptions)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PendingWorkloadOptions) DeepCopyObject ¶
func (in *PendingWorkloadOptions) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PendingWorkloadsSummary ¶
type PendingWorkloadsSummary struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Items []PendingWorkload `json:"items"` }
PendingWorkloadsSummary contains a list of pending workloads in the context of the query (within LocalQueue or ClusterQueue).
func (*PendingWorkloadsSummary) DeepCopy ¶
func (in *PendingWorkloadsSummary) DeepCopy() *PendingWorkloadsSummary
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PendingWorkloadsSummary.
func (*PendingWorkloadsSummary) DeepCopyInto ¶
func (in *PendingWorkloadsSummary) DeepCopyInto(out *PendingWorkloadsSummary)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PendingWorkloadsSummary) DeepCopyObject ¶
func (in *PendingWorkloadsSummary) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.