app

Documentation

Overview

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

Index

• func NewProxyCommand() *cobra.Command
• type Conntracker
• type ProxyServer
  • func NewProxyServer(client *kubeclient.Client, config *ProxyServerConfig, ...) (*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)

Functions

func NewProxyCommand

func NewProxyCommand() *cobra.Command

NewProxyCommand creates a *cobra.Command object with default parameters

Types

type Conntracker

type Conntracker interface {
	SetMax(max int) error
	SetTCPEstablishedTimeout(seconds int) error
}

type ProxyServer

type ProxyServer struct {
	Client       *kubeclient.Client
	Config       *ProxyServerConfig
	IptInterface utiliptables.Interface
	Proxier      proxy.ProxyProvider
	Broadcaster  record.EventBroadcaster
	Recorder     record.EventRecorder
	Conntracker  Conntracker // if nil, ignored
}

func NewProxyServer

func NewProxyServer(
	client *kubeclient.Client,
	config *ProxyServerConfig,
	iptInterface utiliptables.Interface,
	proxier proxy.ProxyProvider,
	broadcaster record.EventBroadcaster,
	recorder record.EventRecorder,
	conntracker Conntracker,
) (*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
	NodeRef                        *api.ObjectReference // Reference to this node.
	MasqueradeAll                  bool
	CleanupAndExit                 bool
	KubeAPIQPS                     float32
	KubeAPIBurst                   int
	UDPIdleTimeout                 time.Duration
	ConntrackMax                   int
	ConntrackTCPTimeoutEstablished int // seconds
}

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