Versions in this module Expand all Collapse all v0 v0.2.2 Feb 4, 2015 Changes in this version + const PodInfraContainerImage type HostInterface + GetPodStatus func(name string, uid types.UID) (api.PodStatus, error) type Kubelet + func (kl *Kubelet) GetPodStatus(podFullName string, uid types.UID) (api.PodStatus, error) v0.2.1 Jan 28, 2015 Changes in this version + const ADD + const AllSource + const ApiserverSource + const ConfigSourceAnnotationKey + const EtcdSource + const FileSource + const HTTPSource + const NetworkContainerImage + const REMOVE + const RunOnceManifestDelay + const RunOnceMaxRetries + const RunOnceRetryDelay + const RunOnceRetryDelayBackoff + const SET + const ServerSource + const UPDATE + func EtcdClientOrDie(etcdServerList util.StringList, etcdConfigFile string) *etcd.Client + func GetPodFullName(pod *api.BoundPod) string + func InitHealthChecking(k *Kubelet) + func ListenAndServeKubeletServer(host HostInterface, address net.IP, port uint, enableDebuggingHandlers bool) + func MonitorCAdvisor(k *Kubelet, cp uint) + func ParsePodFullName(podFullName string) (podName, podNamespace string, podAnnotations map[string]string) + func ResolvePort(portReference util.IntOrString, container *api.Container) (int, error) + func SetupCapabilities(allowPrivileged bool) + func SetupEventSending(client *client.Client, hostname string) + func SetupLogging() + type ByCreated []*docker.Container + func (a ByCreated) Len() int + func (a ByCreated) Less(i, j int) bool + func (a ByCreated) Swap(i, j int) + type FlushWriter struct + func (fw *FlushWriter) Write(p []byte) (n int, err error) + type HostInterface interface + GetBoundPods func() ([]api.BoundPod, error) + GetContainerInfo func(podFullName, uuid, containerName string, req *info.ContainerInfoRequest) (*info.ContainerInfo, error) + GetKubeletContainerLogs func(podFullName, containerName, tail string, follow bool, stdout, stderr io.Writer) error + GetMachineInfo func() (*info.MachineInfo, error) + GetPodByName func(namespace, name string) (*api.BoundPod, bool) + GetPodInfo func(name, uuid string) (api.PodInfo, error) + GetRootInfo func(req *info.ContainerInfoRequest) (*info.ContainerInfo, error) + RunInContainer func(name, uuid, container string, cmd []string) ([]byte, error) + ServeLogs func(w http.ResponseWriter, req *http.Request) + type Kubelet struct + func NewMainKubelet(hostname string, dockerClient dockertools.DockerInterface, ...) (*Kubelet, error) + func (kl *Kubelet) BirthCry() + func (kl *Kubelet) GarbageCollectContainers() error + func (kl *Kubelet) GarbageCollectImages() error + func (kl *Kubelet) GarbageCollectLoop() + func (kl *Kubelet) GetBoundPods() ([]api.BoundPod, error) + func (kl *Kubelet) GetCadvisorClient() cadvisorInterface + func (kl *Kubelet) GetContainerInfo(podFullName, uuid, containerName string, req *cadvisor.ContainerInfoRequest) (*cadvisor.ContainerInfo, error) + func (kl *Kubelet) GetKubeletContainerLogs(podFullName, containerName, tail string, follow bool, stdout, stderr io.Writer) error + func (kl *Kubelet) GetMachineInfo() (*cadvisor.MachineInfo, error) + func (kl *Kubelet) GetPodByName(namespace, name string) (*api.BoundPod, bool) + func (kl *Kubelet) GetPodContainerDir(podUID, ctrName string) string + func (kl *Kubelet) GetPodDir(podUID string) string + func (kl *Kubelet) GetPodInfo(podFullName, uuid string) (api.PodInfo, error) + func (kl *Kubelet) GetPodVolumesDir(podUID string) string + func (kl *Kubelet) GetPodsDir() string + func (kl *Kubelet) GetRootDir() string + func (kl *Kubelet) GetRootInfo(req *cadvisor.ContainerInfoRequest) (*cadvisor.ContainerInfo, error) + func (kl *Kubelet) Run(updates <-chan PodUpdate) + func (kl *Kubelet) RunInContainer(podFullName, uuid, container 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) SetCadvisorClient(c cadvisorInterface) + func (kl *Kubelet) SyncPods(pods []api.BoundPod) error + type PodOperation int + type PodUpdate struct + Op PodOperation + Pods []api.BoundPod + Source string + type RunPodResult struct + Err error + Pod *api.BoundPod + 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 SourceReadyFn func(source string) bool + type SyncHandler interface + SyncPods func([]api.BoundPod) error