update return and apiserver
Signed-off-by: f10atin9 <f10atin9@kubesphere.io>
This commit is contained in:
@@ -42,11 +42,8 @@ func New(informer informers.SharedInformerFactory) v1alpha3.Interface {
|
|||||||
|
|
||||||
func (p *persistentVolumeGetter) Get(namespace, name string) (runtime.Object, error) {
|
func (p *persistentVolumeGetter) Get(namespace, name string) (runtime.Object, error) {
|
||||||
pv, err := p.informers.Core().V1().PersistentVolumes().Lister().Get(name)
|
pv, err := p.informers.Core().V1().PersistentVolumes().Lister().Get(name)
|
||||||
if err != nil {
|
|
||||||
return pv, err
|
return pv, err
|
||||||
}
|
}
|
||||||
return pv, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (p *persistentVolumeGetter) List(namespace string, query *query.Query) (*api.ListResult, error) {
|
func (p *persistentVolumeGetter) List(namespace string, query *query.Query) (*api.ListResult, error) {
|
||||||
all, err := p.informers.Core().V1().PersistentVolumes().Lister().List(query.Selector())
|
all, err := p.informers.Core().V1().PersistentVolumes().Lister().List(query.Selector())
|
||||||
|
|||||||
@@ -114,8 +114,8 @@ func NewResourceGetter(factory informers.InformerFactory, cache cache.Cache) *Re
|
|||||||
namespacedResourceGetters[schema.GroupVersionResource{Group: "networking.k8s.io", Version: "v1", Resource: "networkpolicies"}] = networkpolicy.New(factory.KubernetesSharedInformerFactory())
|
namespacedResourceGetters[schema.GroupVersionResource{Group: "networking.k8s.io", Version: "v1", Resource: "networkpolicies"}] = networkpolicy.New(factory.KubernetesSharedInformerFactory())
|
||||||
namespacedResourceGetters[schema.GroupVersionResource{Group: "batch", Version: "v1", Resource: "jobs"}] = job.New(factory.KubernetesSharedInformerFactory())
|
namespacedResourceGetters[schema.GroupVersionResource{Group: "batch", Version: "v1", Resource: "jobs"}] = job.New(factory.KubernetesSharedInformerFactory())
|
||||||
namespacedResourceGetters[schema.GroupVersionResource{Group: "app.k8s.io", Version: "v1beta1", Resource: "applications"}] = application.New(cache)
|
namespacedResourceGetters[schema.GroupVersionResource{Group: "app.k8s.io", Version: "v1beta1", Resource: "applications"}] = application.New(cache)
|
||||||
|
clusterResourceGetters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "persistentvolumes"}] = persistentvolume.New(factory.KubernetesSharedInformerFactory())
|
||||||
namespacedResourceGetters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "persistentvolumeclaims"}] = persistentvolumeclaim.New(factory.KubernetesSharedInformerFactory(), factory.SnapshotSharedInformerFactory())
|
namespacedResourceGetters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "persistentvolumeclaims"}] = persistentvolumeclaim.New(factory.KubernetesSharedInformerFactory(), factory.SnapshotSharedInformerFactory())
|
||||||
namespacedResourceGetters[schema.GroupVersionResource{Group: "", Version: "v1", Resource: "persistentvolumes"}] = persistentvolume.New(factory.KubernetesSharedInformerFactory())
|
|
||||||
namespacedResourceGetters[snapshotv1beta1.SchemeGroupVersion.WithResource("volumesnapshots")] = volumesnapshot.New(factory.SnapshotSharedInformerFactory())
|
namespacedResourceGetters[snapshotv1beta1.SchemeGroupVersion.WithResource("volumesnapshots")] = volumesnapshot.New(factory.SnapshotSharedInformerFactory())
|
||||||
namespacedResourceGetters[rbacv1.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralRoleBinding)] = rolebinding.New(factory.KubernetesSharedInformerFactory())
|
namespacedResourceGetters[rbacv1.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralRoleBinding)] = rolebinding.New(factory.KubernetesSharedInformerFactory())
|
||||||
namespacedResourceGetters[rbacv1.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralRole)] = role.New(factory.KubernetesSharedInformerFactory())
|
namespacedResourceGetters[rbacv1.SchemeGroupVersion.WithResource(iamv1alpha2.ResourcesPluralRole)] = role.New(factory.KubernetesSharedInformerFactory())
|
||||||
|
|||||||
Reference in New Issue
Block a user