Skip to content

Commit

Permalink
support running workloads in visibility endpoint
Browse files Browse the repository at this point in the history
Signed-off-by: KunWuLuan <kunwuluan@gmail.com>
  • Loading branch information
KunWuLuan committed May 7, 2024
1 parent 9ea94ac commit 96d5e5b
Show file tree
Hide file tree
Showing 19 changed files with 1,427 additions and 13 deletions.
140 changes: 138 additions & 2 deletions apis/visibility/v1alpha1/openapi/zz_generated.openapi.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

34 changes: 33 additions & 1 deletion apis/visibility/v1alpha1/types.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -77,6 +79,35 @@ 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"`
}

// +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

Expand Down Expand Up @@ -117,5 +148,6 @@ func init() {
SchemeBuilder.Register(
&PendingWorkloadsSummary{},
&PendingWorkloadOptions{},
&RunningWorkloadsSummary{},
)
}
83 changes: 82 additions & 1 deletion apis/visibility/v1alpha1/zz_generated.deepcopy.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 4 additions & 0 deletions client-go/applyconfiguration/utils.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

19 changes: 14 additions & 5 deletions client-go/applyconfiguration/visibility/v1alpha1/clusterqueue.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 96d5e5b

Please sign in to comment.