kubelet

package

Go to main page

Versions in this module

v1

v1.1.0

Jun 22, 2016

Changes in this version

+ const ContainerGCPeriod

+ const ImageGCPeriod

type ImageGCPolicy

+ MinAge time.Duration

+ type KillPodOptions struct

+ PodStatusFunc PodStatusFunc

+ PodTerminationGracePeriodSecondsOverride *int64

type Kubelet

+ func (kl *Kubelet) GeneratePodHostNameAndDomain(pod *api.Pod) (string, string, 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) GetPodDir(podUID types.UID) string

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

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

+ 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 OnCompleteFunc func(err error)

+ type Option func(*Kubelet)

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

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

+ 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)

+ type UpdatePodOptions struct

+ KillPodOptions *KillPodOptions

+ MirrorPod *api.Pod

+ OnCompleteFunc OnCompleteFunc

+ Pod *api.Pod

+ UpdateType kubetypes.SyncPodType

v1.1.0-beta3

Jun 10, 2016

v1.1.0-beta2

Jun 3, 2016

v1.1.0-beta1

May 20, 2016

v1.0.1

Mar 31, 2016

v1.0.0

Mar 7, 2016

v1.0.0-beta1

Feb 23, 2016

v0

v0.1.0

Feb 3, 2016

Changes in this version

+ const MaxContainerBackOff

+ const ResolvConfDefault

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

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

+ 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 AuthInterface interface

+ func NewKubeletAuth(authenticator authenticator.Request, ...) AuthInterface

+ type Closer interface

+ Close func() error

+ type DiskSpacePolicy struct

+ DockerFreeDiskMB int

+ RootFreeDiskMB int

+ type FlannelHelper struct

+ func NewFlannelHelper() *FlannelHelper

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

+ 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)

+ 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, auth AuthInterface, ...)

+ 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) 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()

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

+ type KubeletAuth struct

+ type OOMWatcher interface

+ Start func(ref *api.ObjectReference) error

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

+ type PodWorkers interface

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

+ ForgetWorker func(uid types.UID)

+ UpdatePod func(pod *api.Pod, mirrorPod *api.Pod, updateType kubetypes.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, auth AuthInterface, enableDebuggingHandlers bool) Server

+ func (s *Server) InstallAuthFilter()

+ func (s *Server) InstallDebuggingHandlers()

+ func (s *Server) InstallDefaultHandlers()

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

+ type SourcesReadyFn func(sourcesSeen sets.String) 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 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