...

Package app

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

Overview ▾

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.

func NewProxyCommand

func NewProxyCommand() *cobra.Command

NewProxyCommand creates a *cobra.Command object with default parameters

type Conntracker

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 Conntracker interface {
    // SetMax adjusts nf_conntrack_max.
    SetMax(max int) error
    // SetTCPEstablishedTimeout adjusts nf_conntrack_tcp_timeout_established.
    SetTCPEstablishedTimeout(seconds int) error
    // SetTCPCloseWaitTimeout adjusts nf_conntrack_tcp_timeout_close_wait.
    SetTCPCloseWaitTimeout(seconds int) error
    // SetTCPBeLiberal adjusts nf_conntrack_tcp_be_liberal.
    SetTCPBeLiberal(value int) error
    // SetUDPTimeout adjusts nf_conntrack_udp_timeout.
    SetUDPTimeout(seconds int) error
    // SetUDPStreamTimeout adjusts nf_conntrack_udp_timeout_stream.
    SetUDPStreamTimeout(seconds int) error
}

type Options

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

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
    // InitAndExit, when true, makes the proxy server makes configurations that need privileged access, then exit.
    InitAndExit 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
}

func NewOptions

func NewOptions() *Options

NewOptions returns initialized Options

func (*Options) AddFlags

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

AddFlags adds flags to fs and binds them to options.

func (*Options) Complete

func (o *Options) Complete(fs *pflag.FlagSet) error

Complete completes all the required options.

func (*Options) Run

func (o *Options) Run() error

Run runs the specified ProxyServer.

func (*Options) Validate

func (o *Options) Validate() error

Validate validates all the required options.

type ProxyServer

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

type ProxyServer struct {
    Config *kubeproxyconfig.KubeProxyConfiguration

    Client          clientset.Interface
    Broadcaster     events.EventBroadcaster
    Recorder        events.EventRecorder
    NodeRef         *v1.ObjectReference
    HealthzServer   *healthcheck.ProxierHealthServer
    Hostname        string
    PrimaryIPFamily v1.IPFamily
    NodeIPs         map[v1.IPFamily]net.IP

    Proxier proxy.Provider
    // contains filtered or unexported fields
}

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.