package app

import "k8s.io/kubernetes/cmd/kube-proxy/app"

Package app does all of the work necessary to configure and run a Kubernetes app process.

Index ¶

• type ProxyServer
• func NewProxyServer( config *ProxyServerConfig, client *kubeclient.Client, endpointsConfig *proxyconfig.EndpointsConfig, endpointsHandler proxyconfig.EndpointsConfigHandler, iptInterface utiliptables.Interface, oomAdjuster *oom.OomAdjuster, proxier proxy.ProxyProvider, recorder record.EventRecorder, serviceConfig *proxyconfig.ServiceConfig, ) (*ProxyServer, error)
• func NewProxyServerDefault(config *ProxyServerConfig) (*ProxyServer, error)
• func (s *ProxyServer) Run(_ []string) error
• type ProxyServerConfig
• func NewProxyConfig() *ProxyServerConfig
• func (s *ProxyServerConfig) AddFlags(fs *pflag.FlagSet)

Types ¶

type ProxyServer ¶

type ProxyServer struct {
	Client           *kubeclient.Client
	Config           *ProxyServerConfig
	EndpointsConfig  *proxyconfig.EndpointsConfig
	EndpointsHandler proxyconfig.EndpointsConfigHandler
	IptInterface     utiliptables.Interface
	OomAdjuster      *oom.OomAdjuster
	Proxier          proxy.ProxyProvider
	Recorder         record.EventRecorder
	ServiceConfig    *proxyconfig.ServiceConfig
}

func NewProxyServer ¶

func NewProxyServer(
	config *ProxyServerConfig,
	client *kubeclient.Client,
	endpointsConfig *proxyconfig.EndpointsConfig,
	endpointsHandler proxyconfig.EndpointsConfigHandler,
	iptInterface utiliptables.Interface,
	oomAdjuster *oom.OomAdjuster,
	proxier proxy.ProxyProvider,
	recorder record.EventRecorder,
	serviceConfig *proxyconfig.ServiceConfig,
) (*ProxyServer, error)

func NewProxyServerDefault ¶

func NewProxyServerDefault(config *ProxyServerConfig) (*ProxyServer, error)

NewProxyServerDefault creates a new ProxyServer object with default parameters.

func (*ProxyServer) Run ¶

func (s *ProxyServer) Run(_ []string) error

Run runs the specified ProxyServer. This should never exit (unless CleanupAndExit is set).

type ProxyServerConfig ¶

type ProxyServerConfig struct {
	BindAddress        net.IP
	HealthzPort        int
	HealthzBindAddress net.IP
	OOMScoreAdj        int
	ResourceContainer  string
	Master             string
	Kubeconfig         string
	PortRange          util.PortRange
	HostnameOverride   string
	ProxyMode          string
	SyncPeriod         time.Duration

	MasqueradeAll  bool
	CleanupAndExit bool
	// contains filtered or unexported fields
}

ProxyServerConfig contains configures and runs a Kubernetes proxy server

func NewProxyConfig ¶

func NewProxyConfig() *ProxyServerConfig

func (*ProxyServerConfig) AddFlags ¶

func (s *ProxyServerConfig) AddFlags(fs *pflag.FlagSet)

AddFlags adds flags for a specific ProxyServer to the specified FlagSet

Source Files ¶

server.go