Documentation
¶
Overview ¶
Package app makes it easy to create a kubelet server for various contexts.
Index ¶
- func BootstrapKubeletConfigController(dynamicConfigDir string, transform dynamickubeletconfig.TransformFunc) (*kubeletconfiginternal.KubeletConfiguration, *dynamickubeletconfig.Controller, ...)
- func BuildAuth(nodeName types.NodeName, client clientset.Interface, ...) (server.AuthInterface, func(<-chan struct{}), error)
- func BuildAuthn(client authenticationclient.TokenReviewInterface, ...) (authenticator.Request, func(<-chan struct{}), error)
- func BuildAuthz(client authorizationclient.SubjectAccessReviewInterface, ...) (authorizer.Authorizer, error)
- func GetDynamicPluginProber(pluginDir string, runner exec.Interface) volume.DynamicPluginProber
- func InitializeTLS(kf *options.KubeletFlags, kc *kubeletconfiginternal.KubeletConfiguration) (*server.TLSOptions, error)
- func NewKubeletCommand() *cobra.Command
- func ProbeVolumePlugins(featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error)
- func Run(s *options.KubeletServer, kubeDeps *kubelet.Dependencies, ...) error
- func RunKubelet(kubeServer *options.KubeletServer, kubeDeps *kubelet.Dependencies, ...) error
- func UnsecuredDependencies(s *options.KubeletServer, featureGate featuregate.FeatureGate) (*kubelet.Dependencies, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BootstrapKubeletConfigController ¶ added in v1.8.0
func BootstrapKubeletConfigController(dynamicConfigDir string, transform dynamickubeletconfig.TransformFunc) (*kubeletconfiginternal.KubeletConfiguration, *dynamickubeletconfig.Controller, error)
BootstrapKubeletConfigController constructs and bootstrap a configuration controller
func BuildAuth ¶ added in v1.7.0
func BuildAuth(nodeName types.NodeName, client clientset.Interface, config kubeletconfig.KubeletConfiguration) (server.AuthInterface, func(<-chan struct{}), error)
BuildAuth creates an authenticator, an authorizer, and a matching authorizer attributes getter compatible with the kubelet's needs It returns AuthInterface, a run method to start internal controllers (like cert reloading) and error.
func BuildAuthn ¶ added in v1.7.0
func BuildAuthn(client authenticationclient.TokenReviewInterface, authn kubeletconfig.KubeletAuthentication) (authenticator.Request, func(<-chan struct{}), error)
BuildAuthn creates an authenticator compatible with the kubelet's needs
func BuildAuthz ¶ added in v1.7.0
func BuildAuthz(client authorizationclient.SubjectAccessReviewInterface, authz kubeletconfig.KubeletAuthorization) (authorizer.Authorizer, error)
BuildAuthz creates an authorizer compatible with the kubelet's needs
func GetDynamicPluginProber ¶ added in v1.8.0
func GetDynamicPluginProber(pluginDir string, runner exec.Interface) volume.DynamicPluginProber
GetDynamicPluginProber gets the probers of dynamically discoverable plugins for kubelet. Currently only Flexvolume plugins are dynamically discoverable.
func InitializeTLS ¶ added in v1.2.0
func InitializeTLS(kf *options.KubeletFlags, kc *kubeletconfiginternal.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 ¶ added in v1.1.1
NewKubeletCommand creates a *cobra.Command object with default parameters
func ProbeVolumePlugins ¶
func ProbeVolumePlugins(featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error)
ProbeVolumePlugins collects all volume plugins into an easy to use list.
func Run ¶ added in v1.2.0
func Run(s *options.KubeletServer, kubeDeps *kubelet.Dependencies, featureGate featuregate.FeatureGate, stopCh <-chan struct{}) error
Run runs the specified KubeletServer with the given Dependencies. 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 Dependencies object and a default one will not be generated.
func RunKubelet ¶ added in v0.12.0
func RunKubelet(kubeServer *options.KubeletServer, kubeDeps *kubelet.Dependencies, runOnce 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 UnsecuredDependencies ¶ added in v1.8.0
func UnsecuredDependencies(s *options.KubeletServer, featureGate featuregate.FeatureGate) (*kubelet.Dependencies, error)
UnsecuredDependencies returns a Dependencies 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
Types ¶
This section is empty.