package peerproxy

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

Index ¶

• Constants
• func NewPeerProxyHandler( serverId string, identityLeaseLabelSelector string, leaseInformer coordinationv1informers.LeaseInformer, reconciler reconcilers.PeerEndpointLeaseReconciler, ser runtime.NegotiatedSerializer, loopbackClientConfig *rest.Config, proxyClientConfig *transport.Config, ) (*peerProxyHandler, error)
• type Interface

Constants ¶

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

Functions ¶

func NewPeerProxyHandler ¶

func NewPeerProxyHandler(
	serverId string,
	identityLeaseLabelSelector string,
	leaseInformer coordinationv1informers.LeaseInformer,
	reconciler reconcilers.PeerEndpointLeaseReconciler,
	ser runtime.NegotiatedSerializer,
	loopbackClientConfig *rest.Config,
	proxyClientConfig *transport.Config,
) (*peerProxyHandler, error)

New creates a new instance to implement unknown version proxy This method is used for an alpha feature UnknownVersionInteroperabilityProxy and is subject to future modifications.

Types ¶

type Interface ¶

type Interface interface {
	WrapHandler(handler http.Handler) http.Handler
	WaitForCacheSync(stopCh <-chan struct{}) error
	HasFinishedSync() bool
	RunLocalDiscoveryCacheSync(stopCh <-chan struct{}) error
	RunPeerDiscoveryCacheSync(ctx context.Context, workers int)
}

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

Source Files ¶

peer_discovery.go peerproxy.go peerproxy_handler.go

Directories ¶