app

Documentation

Overview

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

Index

• func BuildAuth(nodeName types.NodeName, client clientset.Interface, ...) (server.AuthInterface, error)
• func BuildAuthn(client authenticationclient.TokenReviewInterface, ...) (authenticator.Request, error)
• func BuildAuthz(client authorizationclient.SubjectAccessReviewInterface, ...) (authorizer.Authorizer, error)
• func CreateAPIServerClientConfig(s *options.KubeletServer) (*restclient.Config, error)
• func CreateAndInitKubelet(kubeCfg *componentconfig.KubeletConfiguration, kubeDeps *kubelet.KubeletDeps, ...) (k kubelet.KubeletBootstrap, err error)
• func InitializeTLS(kf *options.KubeletFlags, kc *componentconfig.KubeletConfiguration) (*server.TLSOptions, error)
• func NewKubeletCommand() *cobra.Command
• func ProbeNetworkPlugins(pluginDir, cniConfDir, cniBinDir string) []network.NetworkPlugin
• func ProbeVolumePlugins(pluginDir string) []volume.VolumePlugin
• func Run(s *options.KubeletServer, kubeDeps *kubelet.KubeletDeps) error
• func RunDockershim(c *componentconfig.KubeletConfiguration, r *options.ContainerRuntimeOptions) error
• func RunKubelet(kubeFlags *options.KubeletFlags, kubeCfg *componentconfig.KubeletConfiguration, ...) error
• func UnsecuredKubeletDeps(s *options.KubeletServer) (*kubelet.KubeletDeps, error)

Functions

func BuildAuth

func BuildAuth(nodeName types.NodeName, client clientset.Interface, config componentconfig.KubeletConfiguration) (server.AuthInterface, error)

BuildAuth creates an authenticator, an authorizer, and a matching authorizer attributes getter compatible with the kubelet's needs

func BuildAuthn

func BuildAuthn(client authenticationclient.TokenReviewInterface, authn componentconfig.KubeletAuthentication) (authenticator.Request, error)

BuildAuthn creates an authenticator compatible with the kubelet's needs

func BuildAuthz

func BuildAuthz(client authorizationclient.SubjectAccessReviewInterface, authz componentconfig.KubeletAuthorization) (authorizer.Authorizer, error)

BuildAuthz creates an authorizer compatible with the kubelet's needs

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, crOptions *options.ContainerRuntimeOptions, standaloneMode bool, hostnameOverride, nodeIP, providerID string) (k kubelet.KubeletBootstrap, err error)

func InitializeTLS

func InitializeTLS(kf *options.KubeletFlags, 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, cniConfDir, cniBinDir 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 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 RunDockershim

func RunDockershim(c *componentconfig.KubeletConfiguration, r *options.ContainerRuntimeOptions) error

RunDockershim only starts the dockershim in current process. This is only used for cri validate testing purpose TODO(random-liu): Move this to a separate binary.

func RunKubelet

func RunKubelet(kubeFlags *options.KubeletFlags, 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