Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const ContainerGCPeriod + const ContainerLogsDir + const ImageGCPeriod + const KubeFirewallChain + const KubeMarkDropChain + const KubeMarkMasqChain + const KubePostroutingChain + const MaxContainerBackOff + const NetworkNotReadyErrorMsg + var ErrNetworkUnknown = errors.New("network state unknown") + func NewInitializedVolumePluginMgr(kubelet *Kubelet, secretManager secret.Manager, ...) (*volume.VolumePluginMgr, error) + type Bootstrap interface + BirthCry func() + GetConfiguration func() kubeletconfiginternal.KubeletConfiguration + ListenAndServe func(address net.IP, port uint, tlsOptions *server.TLSOptions, ...) + ListenAndServePodResources func() + ListenAndServeReadOnly func(address net.IP, port uint, enableCAdvisorJSONEndpoints bool) + Run func(<-chan kubetypes.PodUpdate) + RunOnce func(<-chan kubetypes.PodUpdate) ([]RunPodResult, error) + StartGarbageCollection func() + type Builder func(kubeCfg *kubeletconfiginternal.KubeletConfiguration, kubeDeps *Dependencies, ...) (Bootstrap, error) + type CachedNodeInfo struct + func (c *CachedNodeInfo) GetNodeInfo(nodeName string) (*v1.Node, error) + type Dependencies struct + Auth server.AuthInterface + CAdvisorInterface cadvisor.Interface + Cloud cloudprovider.Interface + ContainerManager cm.ContainerManager + DockerClientConfig *dockershim.ClientConfig + DynamicPluginProber volume.DynamicPluginProber + EventClient v1core.EventsGetter + HeartbeatClient clientset.Interface + HostUtil hostutil.HostUtils + KubeClient clientset.Interface + KubeletConfigController *kubeletconfig.Controller + Mounter mount.Interface + OOMAdjuster *oom.OOMAdjuster + OSInterface kubecontainer.OSInterface + OnHeartbeatFailure func() + Options []Option + PodConfig *config.PodConfig + Recorder record.EventRecorder + Subpather subpath.Interface + TLSOptions *server.TLSOptions + VolumePlugins []volume.VolumePlugin + type KillPodOptions struct + PodStatusFunc PodStatusFunc + PodTerminationGracePeriodSecondsOverride *int64 + type Kubelet struct + func NewMainKubelet(kubeCfg *kubeletconfiginternal.KubeletConfiguration, kubeDeps *Dependencies, ...) (*Kubelet, error) + func (kl *Kubelet) BirthCry() + func (kl *Kubelet) GeneratePodHostNameAndDomain(pod *v1.Pod) (string, string, error) + func (kl *Kubelet) GenerateRunContainerOptions(pod *v1.Pod, container *v1.Container, podIP string) (*kubecontainer.RunContainerOptions, func(), error) + func (kl *Kubelet) GetActivePods() []*v1.Pod + func (kl *Kubelet) GetAttach(podFullName string, podUID types.UID, containerName string, ...) (*url.URL, error) + func (kl *Kubelet) GetCachedMachineInfo() (*cadvisorapiv1.MachineInfo, error) + func (kl *Kubelet) GetConfiguration() kubeletconfiginternal.KubeletConfiguration + func (kl *Kubelet) GetExec(podFullName string, podUID types.UID, containerName string, cmd []string, ...) (*url.URL, error) + func (kl *Kubelet) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64 + func (kl *Kubelet) GetHostIP() (net.IP, error) + func (kl *Kubelet) GetHostname() string + func (kl *Kubelet) GetKubeletContainerLogs(ctx context.Context, podFullName, containerName string, ...) error + func (kl *Kubelet) GetNode() (*v1.Node, error) + func (kl *Kubelet) GetNodeConfig() cm.NodeConfig + func (kl *Kubelet) GetPodByCgroupfs(cgroupfs string) (*v1.Pod, bool) + func (kl *Kubelet) GetPodByFullName(podFullName string) (*v1.Pod, bool) + func (kl *Kubelet) GetPodByName(namespace, name string) (*v1.Pod, bool) + func (kl *Kubelet) GetPodCgroupParent(pod *v1.Pod) string + func (kl *Kubelet) GetPodCgroupRoot() string + func (kl *Kubelet) GetPodDNS(pod *v1.Pod) (*runtimeapi.DNSConfig, error) + func (kl *Kubelet) GetPodDir(podUID types.UID) string + func (kl *Kubelet) GetPods() []*v1.Pod + func (kl *Kubelet) GetPortForward(podName, podNamespace string, podUID types.UID, ...) (*url.URL, error) + func (kl *Kubelet) GetRunningPods() ([]*v1.Pod, error) + func (kl *Kubelet) GetVersionInfo() (*cadvisorapiv1.VersionInfo, error) + func (kl *Kubelet) HandlePodAdditions(pods []*v1.Pod) + func (kl *Kubelet) HandlePodCleanups() error + func (kl *Kubelet) HandlePodReconcile(pods []*v1.Pod) + func (kl *Kubelet) HandlePodRemoves(pods []*v1.Pod) + func (kl *Kubelet) HandlePodSyncs(pods []*v1.Pod) + func (kl *Kubelet) HandlePodUpdates(pods []*v1.Pod) + func (kl *Kubelet) IsPodDeleted(uid types.UID) bool + func (kl *Kubelet) IsPodTerminated(uid types.UID) bool + func (kl *Kubelet) LatestLoopEntryTime() time.Time + func (kl *Kubelet) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool) + func (kl *Kubelet) ListenAndServe(address net.IP, port uint, tlsOptions *server.TLSOptions, ...) + func (kl *Kubelet) ListenAndServePodResources() + func (kl *Kubelet) ListenAndServeReadOnly(address net.IP, port uint, enableCAdvisorJSONEndpoints bool) + func (kl *Kubelet) PodResourcesAreReclaimed(pod *v1.Pod, status v1.PodStatus) bool + func (kl *Kubelet) ResyncInterval() time.Duration + func (kl *Kubelet) Run(updates <-chan kubetypes.PodUpdate) + func (kl *Kubelet) RunInContainer(podFullName string, podUID types.UID, containerName string, cmd []string) ([]byte, error) + func (kl *Kubelet) RunOnce(updates <-chan kubetypes.PodUpdate) ([]RunPodResult, error) + func (kl *Kubelet) ServeLogs(w http.ResponseWriter, req *http.Request) + func (kl *Kubelet) StartGarbageCollection() + type OnCompleteFunc func(err error) + type Option func(*Kubelet) + type PodStatusFunc func(pod *v1.Pod, podStatus *kubecontainer.PodStatus) v1.PodStatus + type PodWorkers interface + ForgetNonExistingPodWorkers func(desiredPods map[types.UID]sets.Empty) + ForgetWorker func(uid types.UID) + UpdatePod func(options *UpdatePodOptions) + type ReasonCache struct + func NewReasonCache() *ReasonCache + func (c *ReasonCache) Get(uid types.UID, name string) (*ReasonItem, bool) + func (c *ReasonCache) Remove(uid types.UID, name string) + func (c *ReasonCache) Update(uid types.UID, result kubecontainer.PodSyncResult) + type ReasonItem struct + Err error + Message string + type RunPodResult struct + Err error + Pod *v1.Pod + type SyncHandler interface + HandlePodAdditions func(pods []*v1.Pod) + HandlePodCleanups func() error + HandlePodReconcile func(pods []*v1.Pod) + HandlePodRemoves func(pods []*v1.Pod) + HandlePodSyncs func(pods []*v1.Pod) + HandlePodUpdates func(pods []*v1.Pod) + type UpdatePodOptions struct + KillPodOptions *KillPodOptions + MirrorPod *v1.Pod + OnCompleteFunc OnCompleteFunc + Pod *v1.Pod + UpdateType kubetypes.SyncPodType