server

Documentation

Index

• Variables
• type RequestInterceptor
  • func NewRequestInterceptor(udsSockFile string, cfg *tls.Config) *RequestInterceptor
  • func (ri *RequestInterceptor) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type TunnelServer
  • func NewTunnelServer(egressSelectorEnabled bool, ...) TunnelServer

Variables

var (
	HeaderTransferEncoding = "Transfer-Encoding"
	HeaderChunked          = "chunked"
)

Types

type RequestInterceptor

type RequestInterceptor struct {
	// contains filtered or unexported fields
}

ReqRequestInterceptor intercepts http/https requests sent from the master, prometheus and metric server, setup proxy tunnel to kubelet, sends requests through the tunnel and sends responses back to the master

func NewRequestInterceptor

func NewRequestInterceptor(udsSockFile string, cfg *tls.Config) *RequestInterceptor

NewRequestInterceptor creates a interceptor object that intercept request from kube-apiserver

func (*RequestInterceptor) ServeHTTP

func (ri *RequestInterceptor) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP will proxy the request to the tunnel and return response from tunnel back to the client

type TunnelServer

type TunnelServer interface {
	Run() error
}

TunnelServermanages tunnels between itself and agents, receives requests from apiserver, and forwards requests to corresponding agents

func NewTunnelServer

func NewTunnelServer(
	egressSelectorEnabled bool,
	interceptorServerUDSFile,
	serverMasterAddr,
	serverMasterInsecureAddr,
	serverAgentAddr string,
	serverCount int,
	tlsCfg *tls.Config,
	proxyClientTlsCfg *tls.Config,
	wrappers hw.HandlerWrappers,
	proxyStrategy string) TunnelServer

NewTunnelServer returns a new TunnelServer