浏览代码

add label selector to stream jobs endpoint

Alexander Belanger 4 年之前
父节点
当前提交
9225795d21
共有 1 个文件被更改,包括 3 次插入2 次删除
  1. 3 2
      internal/kubernetes/agent.go

+ 3 - 2
internal/kubernetes/agent.go

@@ -761,8 +761,9 @@ func (a *Agent) StreamJobs(namespace string, selectors string, rw *websocket.Web
 				jobs, err := a.Clientset.BatchV1().Jobs(namespace).List(
 					ctx,
 					metav1.ListOptions{
-						Limit:    100,
-						Continue: continueVal,
+						Limit:         100,
+						Continue:      continueVal,
+						LabelSelector: "meta.helm.sh/release-name",
 					},
 				)