package peerproxy

import "k8s.io/apiserver/pkg/util/peerproxy"

Index ¶

• Constants
• func NewPeerProxyHandler(informerFactory kubeinformers.SharedInformerFactory, svm storageversion.Manager, proxyTransport http.RoundTripper, serverId string, reconciler reconcilers.PeerEndpointLeaseReconciler, serializer runtime.NegotiatedSerializer) *peerProxyHandler
• type Interface

Constants ¶

const (
	PeerProxiedHeader = "x-kubernetes-peer-proxied"
)

Functions ¶

func NewPeerProxyHandler ¶

func NewPeerProxyHandler(informerFactory kubeinformers.SharedInformerFactory,
	svm storageversion.Manager,
	proxyTransport http.RoundTripper,
	serverId string,
	reconciler reconcilers.PeerEndpointLeaseReconciler,
	serializer runtime.NegotiatedSerializer) *peerProxyHandler

New creates a new instance to implement unknown version proxy

Types ¶

type Interface ¶

type Interface interface {
	WrapHandler(handler http.Handler) http.Handler
	WaitForCacheSync(stopCh <-chan struct{}) error
	HasFinishedSync() bool
}

Interface defines how the Unknown Version Proxy filter interacts with the underlying system.

Source Files ¶

peerproxy.go peerproxy_handler.go

Directories ¶