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, iptInterface utiliptables.Interface, proxier proxy.ProxyProvider, recorder record.EventRecorder, ) (*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 {
	Config       *ProxyServerConfig
	IptInterface utiliptables.Interface
	Proxier      proxy.ProxyProvider
	Recorder     record.EventRecorder
}

func NewProxyServer ¶

func NewProxyServer(
	config *ProxyServerConfig,
	iptInterface utiliptables.Interface,
	proxier proxy.ProxyProvider,
	recorder record.EventRecorder,
) (*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
	IptablesSyncPeriod time.Duration
	ConfigSyncPeriod   time.Duration

	MasqueradeAll  bool
	CleanupAndExit bool
	KubeApiQps     float32
	KubeApiBurst   int
	// 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