support running workloads in visibility endpoint

apis/visibility/v1alpha1/types.go

@@ -25,11 +25,13 @@ import (
 // +k8s:openapi-gen=true
 // +genclient:nonNamespaced
 // +genclient:method=GetPendingWorkloadsSummary,verb=get,subresource=pendingworkloads,result=sigs.k8s.io/kueue/apis/visibility/v1alpha1.PendingWorkloadsSummary
+// +genclient:method=GetRunningWorkloadsSummary,verb=get,subresource=runningWorkloads,result=sigs.k8s.io/kueue/apis/visibility/v1alpha1.RunningWorkloadsSummary
 type ClusterQueue struct {
 	metav1.TypeMeta   `json:",inline"`
 	metav1.ObjectMeta `json:"metadata,omitempty"`
 
-	Summary PendingWorkloadsSummary `json:"pendingWorkloadsSummary"`
+	PendingWorkloadsSummary PendingWorkloadsSummary `json:"pendingWorkloadsSummary"`
+	RunningWorkloadsSummary RunningWorkloadsSummary `json:"runningWorkloadsSummary"`
 }
 
 // +kubebuilder:object:root=true
@@ -77,6 +79,37 @@ type PendingWorkload struct {
 	PositionInLocalQueue int32 `json:"positionInLocalQueue"`
 }
 
+// RunningWorkload is a user-facing representation of a running workload that summarizes the relevant information for
+// assumed resources in the cluster queue.
+type RunningWorkload struct {
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	// Priority indicates the workload's priority
+	Priority int32 `json:"priority"`
+	// AdmissionTime indecates the time workloads admitted
+	AdmissionTime metav1.Time `json:"admissionTime"`
+}
+
+// +k8s:openapi-gen=true
+// +kubebuilder:object:root=true
+
+// RunningWorkloadsSummary contains a list of running workloads in the context
+// of the query (within LocalQueue or ClusterQueue).
+type RunningWorkloadsSummary struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Items []RunningWorkload `json:"items"`
+}
+
+// +kubebuilder:object:root=true
+type RunningWorkloadsSummaryList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+
+	Items []RunningWorkloadsSummary `json:"items"`
+}
+
 // +k8s:openapi-gen=true
 // +kubebuilder:object:root=true
 
@@ -102,6 +135,22 @@ type PendingWorkloadsSummaryList struct {
 // +k8s:conversion-gen:explicit-from=net/url.Values
 // +k8s:defaulter-gen=true
 
+// RunningWorkloadOptions are query params used in the visibility queries
+type RunningWorkloadOptions 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"`
+}
+
+// +kubebuilder:object:root=true
+// +k8s:openapi-gen=true
+// +k8s:conversion-gen:explicit-from=net/url.Values
+// +k8s:defaulter-gen=true
+
 // PendingWorkloadOptions are query params used in the visibility queries
 type PendingWorkloadOptions struct {
 	metav1.TypeMeta `json:",inline"`
@@ -117,5 +166,7 @@ func init() {
 	SchemeBuilder.Register(
 		&PendingWorkloadsSummary{},
 		&PendingWorkloadOptions{},
+		&RunningWorkloadsSummary{},
+		&RunningWorkloadOptions{},
 	)
 }