kubelet

package

Go to main page

Versions in this module

v1

v1.3.2

Jan 7, 2017

v1.3.1

Sep 22, 2016

v1.3.0

Sep 19, 2016

Changes in this version

+ func NewInitializedVolumePluginMgr(kubelet *Kubelet, plugins []volume.VolumePlugin) (*volume.VolumePluginMgr, error)

+ type KillPodOptions struct

+ PodStatusFunc PodStatusFunc

+ PodTerminationGracePeriodSecondsOverride *int64

type Kubelet

+ func (kl *Kubelet) GeneratePodHostNameAndDomain(pod *api.Pod) (string, string, error)

+ func (kl *Kubelet) GetPodDir(podUID types.UID) string

+ func (kl *Kubelet) ImagesFsInfo() (cadvisorapiv2.FsInfo, error)

+ type OnCompleteFunc func(err error)

+ type PodStatusFunc func(pod *api.Pod, podStatus *kubecontainer.PodStatus) api.PodStatus

+ type UpdatePodOptions struct

+ KillPodOptions *KillPodOptions

+ MirrorPod *api.Pod

+ OnCompleteFunc OnCompleteFunc

+ Pod *api.Pod

+ UpdateType kubetypes.SyncPodType

v1.2.0

Jun 23, 2016

v0

v0.4.0

Jun 23, 2016

Changes in this version

+ const ContainerGCPeriod

+ const ImageGCPeriod

type ImageGCPolicy

+ MinAge time.Duration

type Kubelet

+ func (kl *Kubelet) DockerImagesFsInfo() (cadvisorapiv2.FsInfo, error)

+ func (kl *Kubelet) GetClusterDNS(pod *api.Pod) ([]string, []string, error)

+ func (kl *Kubelet) GetContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error)

+ func (kl *Kubelet) GetNodeConfig() cm.NodeConfig

+ func (kl *Kubelet) HandlePodReconcile(pods []*api.Pod)

+ func (kl *Kubelet) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool)

+ func (kl *Kubelet) PLEGHealthCheck() (bool, error)

+ func (kl *Kubelet) RootFsInfo() (cadvisorapiv2.FsInfo, error)

+ type Option func(*Kubelet)

+ func SetNodeStatus(f func(*api.Node) error) Option

+ type ReasonCache struct

+ func NewReasonCache() *ReasonCache

+ func (c *ReasonCache) Get(uid types.UID, name string) (error, string, bool)

+ func (c *ReasonCache) Remove(uid types.UID, name string)

+ func (c *ReasonCache) Update(uid types.UID, result kubecontainer.PodSyncResult)

type SyncHandler

+ HandlePodReconcile func(pods []*api.Pod)

v0.3.0

Mar 16, 2016

Changes in this version

+ const MaxContainerBackOff

+ type FlannelHelper struct

+ func NewFlannelHelper() *FlannelHelper

+ func (f *FlannelHelper) Handshake() (podCIDR string, err error)

v0.1.0

Oct 25, 2015

Changes in this version

+ const ADD

+ const AllSource

+ const ApiserverSource

+ const ConfigFirstSeenAnnotationKey

+ const ConfigMirrorAnnotationKey

+ const ConfigSourceAnnotationKey

+ const DockerMemoryLimitThresholdPercent — linux/amd64

+ const FileSource

+ const HTTPSource

+ const MinDockerMemoryLimit — linux/amd64

+ const MirrorType

+ const NamespaceDefault

+ const REMOVE

+ const ResolvConfDefault

+ const RunOnceManifestDelay

+ const RunOnceMaxRetries

+ const RunOnceRetryDelay

+ const RunOnceRetryDelayBackoff

+ const SET

+ const TenantDefault

+ const UPDATE

+ var ErrContainerNotFound = errors.New("no matching container")

+ func CapacityFromMachineInfo(info *cadvisorApi.MachineInfo) api.ResourceList

+ func GetPhase(spec *api.PodSpec, info []api.ContainerStatus) api.PodPhase

+ func GetValidatedSources(sources []string) ([]string, error)

+ func ListenAndServeKubeletReadOnlyServer(host HostInterface, address net.IP, port uint)

+ func ListenAndServeKubeletServer(host HostInterface, address net.IP, port uint, tlsOptions *TLSOptions, ...)

+ func ServePortForward(w http.ResponseWriter, req *http.Request, portForwarder PortForwarder, ...)

+ type ContainerGCPolicy struct

+ MaxContainers int

+ MaxPerPodContainer int

+ MinAge time.Duration

+ type DiskSpacePolicy struct

+ DockerFreeDiskMB int

+ RootFreeDiskMB int

+ type HostInterface interface

+ AttachContainer func(name string, uid types.UID, container string, in io.Reader, ...) error

+ ExecInContainer func(name string, uid types.UID, container string, cmd []string, in io.Reader, ...) error

+ GetCachedMachineInfo func() (*cadvisorApi.MachineInfo, error)

+ GetContainerInfo func(podFullName string, uid types.UID, containerName string, ...) (*cadvisorApi.ContainerInfo, error)

+ GetContainerRuntimeVersion func() (kubecontainer.Version, error)

+ GetHostname func() string

+ GetKubeletContainerLogs func(podFullName, containerName string, logOptions *api.PodLogOptions, ...) error

+ GetPodByName func(namespace, name string) (*api.Pod, bool)

+ GetPods func() []*api.Pod

+ GetRawContainerInfo func(containerName string, req *cadvisorApi.ContainerInfoRequest, ...) (map[string]*cadvisorApi.ContainerInfo, error)

+ GetRunningPods func() ([]*api.Pod, error)

+ LatestLoopEntryTime func() time.Time

+ PortForward func(name string, uid types.UID, port uint16, stream io.ReadWriteCloser) error

+ ResyncInterval func() time.Duration

+ RunInContainer func(name string, uid types.UID, container string, cmd []string) ([]byte, error)

+ ServeLogs func(w http.ResponseWriter, req *http.Request)

+ StreamingConnectionIdleTimeout func() time.Duration

+ type ImageGCPolicy struct

+ HighThresholdPercent int

+ LowThresholdPercent int

+ type Kubelet struct

+ func NewMainKubelet(hostname string, nodeName string, dockerClient dockertools.DockerInterface, ...) (*Kubelet, error)

+ func (kl *Kubelet) AttachContainer(podFullName string, podUID types.UID, containerName string, stdin io.Reader, ...) error

+ func (kl *Kubelet) BirthCry()

+ func (kl *Kubelet) ExecInContainer(podFullName string, podUID types.UID, containerName string, cmd []string, ...) error

+ func (kl *Kubelet) GenerateRunContainerOptions(pod *api.Pod, container *api.Container) (*kubecontainer.RunContainerOptions, error)

+ func (kl *Kubelet) GetCachedMachineInfo() (*cadvisorApi.MachineInfo, error)

+ func (kl *Kubelet) GetContainerInfo(podFullName string, podUID types.UID, containerName string, ...) (*cadvisorApi.ContainerInfo, error)

+ func (kl *Kubelet) GetContainerRuntimeVersion() (kubecontainer.Version, error)

+ func (kl *Kubelet) GetHostIP() (net.IP, error)

+ func (kl *Kubelet) GetHostname() string

+ func (kl *Kubelet) GetKubeletContainerLogs(podFullName, containerName string, logOptions *api.PodLogOptions, ...) error

+ func (kl *Kubelet) GetNode() (*api.Node, error)

+ func (kl *Kubelet) GetPodByFullName(podFullName string) (*api.Pod, bool)

+ func (kl *Kubelet) GetPodByName(namespace, name string) (*api.Pod, bool)

+ func (kl *Kubelet) GetPods() []*api.Pod

+ func (kl *Kubelet) GetRawContainerInfo(containerName string, req *cadvisorApi.ContainerInfoRequest, ...) (map[string]*cadvisorApi.ContainerInfo, error)

+ func (kl *Kubelet) GetRunningPods() ([]*api.Pod, error)

+ func (kl *Kubelet) GetRuntime() kubecontainer.Runtime

+ func (kl *Kubelet) HandlePodAdditions(pods []*api.Pod)

+ func (kl *Kubelet) HandlePodCleanups() error

+ func (kl *Kubelet) HandlePodDeletions(pods []*api.Pod)

+ func (kl *Kubelet) HandlePodSyncs(pods []*api.Pod)

+ func (kl *Kubelet) HandlePodUpdates(pods []*api.Pod)

+ func (kl *Kubelet) LatestLoopEntryTime() time.Time

+ func (kl *Kubelet) ListenAndServe(address net.IP, port uint, tlsOptions *TLSOptions, ...)

+ func (kl *Kubelet) ListenAndServeReadOnly(address net.IP, port uint)

+ func (kl *Kubelet) PortForward(podFullName string, podUID types.UID, port uint16, stream io.ReadWriteCloser) error

+ func (kl *Kubelet) ProbeLiveness(pod *api.Pod, status api.PodStatus, container api.Container, ...) (probe.Result, error)

+ func (kl *Kubelet) ProbeReadiness(pod *api.Pod, status api.PodStatus, container api.Container, ...) (probe.Result, error)

+ func (kl *Kubelet) ResyncInterval() time.Duration

+ func (kl *Kubelet) Run(updates <-chan PodUpdate)

+ func (kl *Kubelet) RunInContainer(podFullName string, podUID types.UID, containerName string, cmd []string) ([]byte, error)

+ func (kl *Kubelet) RunOnce(updates <-chan PodUpdate) ([]RunPodResult, error)

+ func (kl *Kubelet) ServeLogs(w http.ResponseWriter, req *http.Request)

+ func (kl *Kubelet) StartGarbageCollection()

+ func (kl *Kubelet) StreamingConnectionIdleTimeout() time.Duration

+ type OOMWatcher interface

+ Start func(ref *api.ObjectReference) error

+ func NewOOMWatcher(cadvisor cadvisor.Interface, recorder record.EventRecorder) OOMWatcher

+ type PodOperation int

+ type PodUpdate struct

+ Op PodOperation

+ Pods []*api.Pod

+ Source string

+ type PodWorkers interface

+ ForgetNonExistingPodWorkers func(desiredPods map[types.UID]empty)

+ ForgetWorker func(uid types.UID)

+ UpdatePod func(pod *api.Pod, mirrorPod *api.Pod, updateType SyncPodType, ...)

+ type PortForwarder interface

+ PortForward func(name string, uid types.UID, port uint16, stream io.ReadWriteCloser) error

+ type RunPodResult struct

+ Err error

+ Pod *api.Pod

+ type Server struct

+ func NewServer(host HostInterface, enableDebuggingHandlers bool) Server

+ func (s *Server) InstallDebuggingHandlers()

+ func (s *Server) InstallDefaultHandlers()

+ func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type SourcesReadyFn func() bool

+ type StatsRequest struct

+ ContainerName string

+ End time.Time

+ NumStats int

+ Start time.Time

+ Subcontainers bool

+ type SyncHandler interface

+ HandlePodAdditions func(pods []*api.Pod)

+ HandlePodCleanups func() error

+ HandlePodDeletions func(pods []*api.Pod)

+ HandlePodSyncs func(pods []*api.Pod)

+ HandlePodUpdates func(pods []*api.Pod)

+ type SyncPodType int

+ const SyncPodCreate

+ const SyncPodSync

+ const SyncPodUpdate

+ func (sp SyncPodType) String() string

+ type TLSOptions struct

+ CertFile string

+ Config *tls.Config

+ KeyFile string

+ type TestingInterface interface

+ Errorf func(format string, args ...interface{})

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL