Versions in this module Expand all Collapse all v0 v0.20.0 Jun 24, 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 RunOnceManifestDelay + const RunOnceMaxRetries + const RunOnceRetryDelay + const RunOnceRetryDelayBackoff + const SET + 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, ...) + type ContainerGCPolicy struct + MaxContainers int + MaxPerPodContainer int + MinAge time.Duration + type DiskSpacePolicy struct + DockerFreeDiskMB int + RootFreeDiskMB int + type HostInterface interface + 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, tail string, follow, previous bool, ...) 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) + 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) 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, tail string, follow, previous bool, ...) 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) GetRuntime() kubecontainer.Runtime + 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) 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 + func (kl *Kubelet) SyncPods(allPods []*api.Pod, podSyncTypes map[types.UID]SyncPodType, ...) error + 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) + UpdatePod func(pod *api.Pod, mirrorPod *api.Pod, updateComplete func()) + 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 + SyncPods func(pods []*api.Pod, podSyncTypes map[types.UID]SyncPodType, ...) error + 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{})
Go to main page