Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for addSV (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go

    	}
    	svi := informerFactory.Internal().V1alpha1().StorageVersions()
    	h.storageversionInformer = svi.Informer()
    
    	svi.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			h.addSV(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			h.updateSV(oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			h.deleteSV(obj)
    		}})
    	return h
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go

    	http.Error(w, err.Error(), http.StatusServiceUnavailable)
    }
    
    // Adds a storageversion object to SVMap
    func (h *peerProxyHandler) addSV(obj interface{}) {
    	sv, ok := obj.(*v1alpha1.StorageVersion)
    	if !ok {
    		klog.Errorf("Invalid StorageVersion provided to addSV()")
    		return
    	}
    	h.updateSVMap(nil, sv)
    }
    
    // Updates the SVMap to delete old storageversion and add new storageversion
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 11.5K bytes
    - Viewed (0)
Back to top