Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

newdeploy executor to work with specific namespaces (#2590)

Browse Source
This commit is contained in:
Shubham Bansal
2022-10-31 12:55:57 +05:30
committed by GitHub
parent a64fcc3faf
commit 9ff9a6e075
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/executor/executortype/newdeploy/newdeploymgr.go
+9 -7
View File
@@ -778,14 +778,16 @@ func (deploy *NewDeploy) idleObjectReaper(ctx context.Context) {
} }
func (deploy *NewDeploy) doIdleObjectReaper(ctx context.Context) { func (deploy *NewDeploy) doIdleObjectReaper(ctx context.Context) {
envs, err := deploy.fissionClient.CoreV1().Environments(metav1.NamespaceAll).List(ctx, metav1.ListOptions{})
if err != nil {
deploy.logger.Fatal("failed to get environment list", zap.Error(err))
}
envList := make(map[k8sTypes.UID]struct{}) envList := make(map[k8sTypes.UID]struct{})
for _, env := range envs.Items { for _, namespace := range utils.GetNamespaces() {
envList[env.ObjectMeta.UID] = struct{}{} envs, err := deploy.fissionClient.CoreV1().Environments(namespace).List(ctx, metav1.ListOptions{})
if err != nil {
deploy.logger.Fatal("failed to get environment list", zap.Error(err), zap.String("namespace", namespace))
}
for _, env := range envs.Items {
envList[env.ObjectMeta.UID] = struct{}{}
}
} }
funcSvcs, err := deploy.fsCache.ListOld(time.Second * 5) funcSvcs, err := deploy.fsCache.ListOld(time.Second * 5)