app

Documentation

Overview

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

Index

• func AddFlags(options *Options, fs *pflag.FlagSet)
• func NewProxyCommand() *cobra.Command
• type Conntracker
• type Options
  • func (o Options) Complete() error
  • func (o Options) Run() error
  • func (o Options) Validate(args []string) error
• type ProxyServer
  • func NewProxyServer(config *componentconfig.KubeProxyConfiguration, cleanupAndExit bool, ...) (*ProxyServer, error)
  • func (s *ProxyServer) Run() error

Functions

func AddFlags

func AddFlags(options *Options, fs *pflag.FlagSet)

AddFlags adds flags to fs and binds them to options.

func NewProxyCommand

func NewProxyCommand() *cobra.Command

NewProxyCommand creates a *cobra.Command object with default parameters

Types

type Conntracker

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:

https://www.kernel.org/doc/Documentation/networking/nf_conntrack-sysctl.txt

type Options

type Options struct {
	// ConfigFile is the location of the proxy server's configuration file.
	ConfigFile string
	// CleanupAndExit, when true, makes the proxy server clean up iptables rules, then exit.
	CleanupAndExit bool
	// contains filtered or unexported fields
}

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

func (Options) Complete

func (o Options) Complete() error

Complete completes all the required options.

func (Options) Run

func (o Options) Run() error

func (Options) Validate

func (o Options) Validate(args []string) error

Validate validates all the required options.

type ProxyServer

type ProxyServer struct {
	Client                 clientset.Interface
	EventClient            v1core.EventsGetter
	IptInterface           utiliptables.Interface
	Proxier                proxy.ProxyProvider
	Broadcaster            record.EventBroadcaster
	Recorder               record.EventRecorder
	ConntrackConfiguration componentconfig.KubeProxyConntrackConfiguration
	Conntracker            Conntracker // if nil, ignored
	ProxyMode              string
	NodeRef                *clientv1.ObjectReference
	CleanupAndExit         bool
	HealthzBindAddress     string
	OOMScoreAdj            *int32
	ResourceContainer      string
	ConfigSyncPeriod       time.Duration
	ServiceEventHandler    proxyconfig.ServiceHandler
	// TODO: Migrate all handlers to ServiceHandler types and
	// get rid of this one.
	ServiceHandler        proxyconfig.ServiceConfigHandler
	EndpointsEventHandler proxyconfig.EndpointsHandler
}

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

func NewProxyServer

func NewProxyServer(config *componentconfig.KubeProxyConfiguration, cleanupAndExit bool, master string) (*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).