app

Documentation

Overview

Package app makes it easy to create a kubelet server for various contexts.

Index

• func CreateAPIServerClientConfig(s *options.KubeletServer) (*restclient.Config, error)
• func CreateAndInitKubelet(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *kubelet.KubeletDeps, ...) (k kubelet.KubeletBootstrap, err error)
• func InitializeTLS(kc *componentconfig.KubeletConfiguration) (*server.TLSOptions, error)
• func NewKubeletCommand() *cobra.Command
• func ProbeNetworkPlugins(pluginDir string) []network.NetworkPlugin
• func ProbeVolumePlugins(pluginDir string) []volume.VolumePlugin
• func RequestClientCertificate(client unversionedcertificates.CertificateSigningRequestInterface, ...) (certData []byte, err error)
• func Run(s *options.KubeletServer, kubeDeps *kubelet.KubeletDeps) error
• func RunKubelet(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *kubelet.KubeletDeps, ...) error
• func UnsecuredKubeletDeps(s *options.KubeletServer) (*kubelet.KubeletDeps, error)

Functions

func CreateAPIServerClientConfig

func CreateAPIServerClientConfig(s *options.KubeletServer) (*restclient.Config, error)

CreateAPIServerClientConfig generates a client.Config from command line flags, including api-server-list, via createClientConfig and then injects chaos into the configuration via addChaosToClientConfig. This func is exported to support integration with third party kubelet extensions (e.g. kubernetes-mesos).

func CreateAndInitKubelet

func CreateAndInitKubelet(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *kubelet.KubeletDeps, standaloneMode bool) (k kubelet.KubeletBootstrap, err error)

func InitializeTLS

func InitializeTLS(kc *componentconfig.KubeletConfiguration) (*server.TLSOptions, error)

InitializeTLS checks for a configured TLSCertFile and TLSPrivateKeyFile: if unspecified a new self-signed certificate and key file are generated. Returns a configured server.TLSOptions object.

func NewKubeletCommand

func NewKubeletCommand() *cobra.Command

NewKubeletCommand creates a *cobra.Command object with default parameters

func ProbeNetworkPlugins

func ProbeNetworkPlugins(pluginDir string) []network.NetworkPlugin

ProbeNetworkPlugins collects all compiled-in plugins

func ProbeVolumePlugins

func ProbeVolumePlugins(pluginDir string) []volume.VolumePlugin

ProbeVolumePlugins collects all volume plugins into an easy to use list. PluginDir specifies the directory to search for additional third party volume plugins.

func RequestClientCertificate

func RequestClientCertificate(client unversionedcertificates.CertificateSigningRequestInterface, privateKeyData []byte, nodeName string) (certData []byte, err error)

RequestClientCertificate will create a certificate signing request and send it to API server, then it will watch the object's status, once approved by API server, it will return the API server's issued certificate (pem-encoded). If there is any errors, or the watch timeouts, it will return an error.

func Run

func Run(s *options.KubeletServer, kubeDeps *kubelet.KubeletDeps) error

Run runs the specified KubeletServer with the given KubeletDeps. This should never exit. The kubeDeps argument may be nil - if so, it is initialized from the settings on KubeletServer. Otherwise, the caller is assumed to have set up the KubeletDeps object and a default one will not be generated.

func RunKubelet

func RunKubelet(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *kubelet.KubeletDeps, runOnce bool, standaloneMode bool) error

RunKubelet is responsible for setting up and running a kubelet. It is used in three different applications:

1 Integration tests
2 Kubelet binary
3 Standalone 'kubernetes' binary

Eventually, #2 will be replaced with instances of #3

func UnsecuredKubeletDeps

func UnsecuredKubeletDeps(s *options.KubeletServer) (*kubelet.KubeletDeps, error)

UnsecuredKubeletDeps returns a KubeletDeps suitable for being run, or an error if the server setup is not valid. It will not start any background processes, and does not include authentication/authorization