Version: v1.26.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Dec 8, 2022 License: Apache-2.0 Imports: 80 Imported by: 185



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

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



This section is empty.


This section is empty.


func NewProxyCommand added in v1.1.1

func NewProxyCommand() *cobra.Command

NewProxyCommand creates a *cobra.Command object with default parameters


type Conntracker added in v1.2.0

type Conntracker interface {
	// SetMax adjusts nf_conntrack_max.
	SetMax(max int) error
	// SetTCPEstablishedTimeout adjusts nf_conntrack_tcp_timeout_established.
	SetTCPEstablishedTimeout(seconds int) error
	// SetTCPCloseWaitTimeout nf_conntrack_tcp_timeout_close_wait.
	SetTCPCloseWaitTimeout(seconds int) error

Conntracker is an interface to the global sysctl. Descriptions of the various sysctl fields can be found here:

type Options added in v1.7.0

type Options struct {
	// ConfigFile is the location of the proxy server's configuration file.
	ConfigFile string
	// WriteConfigTo is the path where the default configuration will be written.
	WriteConfigTo string
	// CleanupAndExit, when true, makes the proxy server clean up iptables and ipvs rules, then exit.
	CleanupAndExit bool
	// WindowsService should be set to true if kube-proxy is running as a service on Windows.
	// Its corresponding flag only gets registered in Windows builds
	WindowsService bool
	// contains filtered or unexported fields

Options contains everything necessary to create and run a proxy server.

func NewOptions added in v1.7.0

func NewOptions() *Options

NewOptions returns initialized Options

func (*Options) AddFlags added in v1.10.0

func (o *Options) AddFlags(fs *pflag.FlagSet)

AddFlags adds flags to fs and binds them to options.

func (*Options) ApplyDefaults added in v1.8.0

ApplyDefaults applies the default values to Options.

func (*Options) Complete added in v1.7.0

func (o *Options) Complete() error

Complete completes all the required options.

func (*Options) Run added in v1.7.0

func (o *Options) Run() error

Run runs the specified ProxyServer.

func (*Options) Validate added in v1.7.0

func (o *Options) Validate() error

Validate validates all the required options.

type ProxyServer

type ProxyServer struct {
	Client         clientset.Interface
	EventClient    v1core.EventsGetter
	IptInterface   utiliptables.Interface
	IpvsInterface  utilipvs.Interface
	IpsetInterface utilipset.Interface

	Proxier                proxy.Provider
	Broadcaster            events.EventBroadcaster
	Recorder               events.EventRecorder
	ConntrackConfiguration kubeproxyconfig.KubeProxyConntrackConfiguration
	Conntracker            Conntracker // if nil, ignored
	ProxyMode              kubeproxyconfig.ProxyMode
	NodeRef                *v1.ObjectReference
	MetricsBindAddress     string
	BindAddressHardFail    bool
	EnableProfiling        bool
	OOMScoreAdj            *int32
	ConfigSyncPeriod       time.Duration
	HealthzServer          healthcheck.ProxierHealthUpdater
	// contains filtered or unexported fields

ProxyServer represents all the parameters required to start the Kubernetes proxy server. All fields are required.

func NewProxyServer

func NewProxyServer(o *Options) (*ProxyServer, error)

NewProxyServer returns a new ProxyServer.

func (*ProxyServer) Run

func (s *ProxyServer) Run() error

Run runs the specified ProxyServer. This should never exit (unless CleanupAndExit is set). TODO: At the moment, Run() cannot return a nil error, otherwise it's caller will never exit. Update callers of Run to handle nil errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL