mirror of
https://github.com/kubevela/kubevela.git
synced 2026-08-19 04:26:39 +00:00
* Fix: refactor the source of all kinds of views, use the "Factory Method" design patterns to rewrite the code to upgrade the quality of code Signed-off-by: HanMengnan <1448189829@qq.com> * Fix: fix test case of the refactored code and some bugs Signed-off-by: HanMengnan <1448189829@qq.com> * Fix: rename the interface of ResourceView Signed-off-by: HanMengnan <1448189829@qq.com> Signed-off-by: HanMengnan <1448189829@qq.com>
70 lines
2.0 KiB
Go
70 lines
2.0 KiB
Go
/*
|
|
Copyright 2022 The KubeVela Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package model
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
v1 "k8s.io/api/core/v1"
|
|
"k8s.io/apimachinery/pkg/types"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
|
|
"github.com/oam-dev/kubevela/references/cli/top/utils"
|
|
)
|
|
|
|
// ListClusterNamespaces return namespace of application's resource
|
|
func ListClusterNamespaces(ctx context.Context, c client.Client) (NamespaceList, error) {
|
|
name := ctx.Value(&CtxKeyAppName).(string)
|
|
ns := ctx.Value(&CtxKeyNamespace).(string)
|
|
app, err := LoadApplication(c, name, ns)
|
|
if err != nil {
|
|
return NamespaceList{}, err
|
|
}
|
|
clusterNSSet := make(map[string]interface{})
|
|
for _, svc := range app.Status.AppliedResources {
|
|
if svc.Namespace != "" {
|
|
clusterNSSet[svc.Namespace] = struct{}{}
|
|
}
|
|
}
|
|
nsList := make(NamespaceList, len(clusterNSSet))
|
|
index := 0
|
|
for clusterNS := range clusterNSSet {
|
|
namespaceInfo, err := LoadNamespaceDetail(ctx, c, clusterNS)
|
|
if err != nil {
|
|
continue
|
|
}
|
|
nsList[index] = Namespace{
|
|
name: namespaceInfo.Name,
|
|
status: string(namespaceInfo.Status.Phase),
|
|
age: utils.TimeFormat(time.Since(namespaceInfo.CreationTimestamp.Time)),
|
|
}
|
|
index++
|
|
}
|
|
|
|
return nsList, nil
|
|
}
|
|
|
|
// LoadNamespaceDetail query detail info of a namespace by name
|
|
func LoadNamespaceDetail(ctx context.Context, c client.Client, namespace string) (*v1.Namespace, error) {
|
|
ns := new(v1.Namespace)
|
|
if err := c.Get(ctx, types.NamespacedName{Name: namespace}, ns); err != nil {
|
|
return nil, err
|
|
}
|
|
return ns, nil
|
|
}
|