109 lines
6.0 KiB
Go
109 lines
6.0 KiB
Go
/*
|
|
*
|
|
* Copyright 2020 The KubeSphere 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 resource
|
|
|
|
import (
|
|
"errors"
|
|
snapshotv1beta1 "github.com/kubernetes-csi/external-snapshotter/v2/pkg/apis/volumesnapshot/v1beta1"
|
|
rbacv1 "k8s.io/api/rbac/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
"kubesphere.io/kubesphere/pkg/api"
|
|
iamv1alpha2 "kubesphere.io/kubesphere/pkg/apis/iam/v1alpha2"
|
|
tenantv1alpha1 "kubesphere.io/kubesphere/pkg/apis/tenant/v1alpha1"
|
|
"kubesphere.io/kubesphere/pkg/apiserver/query"
|
|
"kubesphere.io/kubesphere/pkg/informers"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/application"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/cluster"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/clusterrole"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/configmap"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/customresourcedefinition"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/deployment"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/globalrole"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/namespace"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/networkpolicy"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/node"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/persistentvolumeclaim"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/pod"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/role"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/user"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/volumesnapshot"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/workspace"
|
|
"kubesphere.io/kubesphere/pkg/models/resources/v1alpha3/workspacerole"
|
|
)
|
|
|
|
var ErrResourceNotSupported = errors.New("resource is not supported")
|
|
|
|
type ResourceGetter struct {
|
|
getters map[schema.GroupVersionResource]v1alpha3.Interface
|
|
}
|
|
|
|
func NewResourceGetter(factory informers.InformerFactory) *ResourceGetter {
|
|
getters := make(map[schema.GroupVersionResource]v1alpha3.Interface)
|
|
|
|
getters[schema.GroupVersionResource{Group: "apps", Version: "v1", Resource: "deployments"}] = deployment.New(factory.KubernetesSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "namespaces"}] = namespace.New(factory.KubernetesSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "configmaps"}] = configmap.New(factory.KubernetesSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "pods"}] = pod.New(factory.KubernetesSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "nodes"}] = node.New(factory.KubernetesSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "app.k8s.io", Version: "v1beta1", Resource: "applications"}] = application.New(factory.ApplicationSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "networking.k8s.io", Version: "v1", Resource: "networkpolicies"}] = networkpolicy.New(factory.KubernetesSharedInformerFactory())
|
|
getters[tenantv1alpha1.SchemeGroupVersion.WithResource(tenantv1alpha1.ResourcePluralWorkspace)] = workspace.New(factory.KubeSphereSharedInformerFactory())
|
|
getters[iamv1alpha2.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralGlobalRole)] = globalrole.New(factory.KubeSphereSharedInformerFactory())
|
|
getters[iamv1alpha2.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralWorkspaceRole)] = workspacerole.New(factory.KubeSphereSharedInformerFactory())
|
|
getters[iamv1alpha2.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralUser)] = user.New(factory.KubeSphereSharedInformerFactory())
|
|
getters[rbacv1.SchemeGroupVersion.WithResource("roles")] = role.New(factory.KubernetesSharedInformerFactory())
|
|
getters[rbacv1.SchemeGroupVersion.WithResource("clusterroles")] = clusterrole.New(factory.KubernetesSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "persistentvolumeclaims"}] = persistentvolumeclaim.New(factory.KubernetesSharedInformerFactory(), factory.SnapshotSharedInformerFactory())
|
|
getters[snapshotv1beta1.SchemeGroupVersion.WithResource("volumesnapshots")] = volumesnapshot.New(factory.SnapshotSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "cluster.kubesphere.io", Version: "v1alpha1", Resource: "clusters"}] = cluster.New(factory.KubeSphereSharedInformerFactory())
|
|
getters[schema.GroupVersionResource{Group: "apiextensions.k8s.io", Version: "v1", Resource: "customresourcedefinitions"}] = customresourcedefinition.New(factory.ApiExtensionSharedInformerFactory())
|
|
return &ResourceGetter{
|
|
getters: getters,
|
|
}
|
|
}
|
|
|
|
// tryResource will retrieve a getter with resource name, it doesn't guarantee find resource with correct group version
|
|
// need to refactor this use schema.GroupVersionResource
|
|
func (r *ResourceGetter) tryResource(resource string) v1alpha3.Interface {
|
|
for k, v := range r.getters {
|
|
if k.Resource == resource {
|
|
return v
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (r *ResourceGetter) Get(resource, namespace, name string) (runtime.Object, error) {
|
|
getter := r.tryResource(resource)
|
|
if getter == nil {
|
|
return nil, ErrResourceNotSupported
|
|
}
|
|
return getter.Get(namespace, name)
|
|
}
|
|
|
|
func (r *ResourceGetter) List(resource, namespace string, query *query.Query) (*api.ListResult, error) {
|
|
getter := r.tryResource(resource)
|
|
if getter == nil {
|
|
return nil, ErrResourceNotSupported
|
|
}
|
|
return getter.List(namespace, query)
|
|
}
|