kubernetes/staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go

const PeerProxiedHeader …

type peerProxyHandler …

type responder …

func (h *peerProxyHandler) HasFinishedSync() bool { … }

func (h *peerProxyHandler) WaitForCacheSync(stopCh <-chan struct{ … }

// WrapHandler will fetch the apiservers that can serve the request and either serve it locally
// or route it to a peer
func (h *peerProxyHandler) WrapHandler(handler http.Handler) http.Handler { … }

func (h *peerProxyHandler) findServiceableByServers(gvr schema.GroupVersionResource) (*sync.Map, error) { … }

func (h *peerProxyHandler) resolveServingLocation(apiservers *sync.Map) (bool, []string, error) { … }

func (h *peerProxyHandler) hostportInfo(apiserverKey string) (string, error) { … }

func (h *peerProxyHandler) proxyRequestToDestinationAPIServer(req *http.Request, rw http.ResponseWriter, host string) { … }

func (r *responder) Error(w http.ResponseWriter, req *http.Request, err error) { … }

// Adds a storageversion object to SVMap
func (h *peerProxyHandler) addSV(obj interface{ … }

// Updates the SVMap to delete old storageversion and add new storageversion
func (h *peerProxyHandler) updateSV(oldObj interface{ … }

// Deletes a storageversion object from SVMap
func (h *peerProxyHandler) deleteSV(obj interface{ … }

// Delete old storageversion, add new storagversion
func (h *peerProxyHandler) updateSVMap(oldSV *v1alpha1.StorageVersion, newSV *v1alpha1.StorageVersion) { … }

func (h *peerProxyHandler) deleteSVFromMap(sv *v1alpha1.StorageVersion) { … }

func (h *peerProxyHandler) addSVToMap(sv *v1alpha1.StorageVersion) { … }