Versions in this module Expand all Collapse all v0 v0.4.2 Oct 29, 2014 Changes in this version + 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 Kubelet + func (kl *Kubelet) GarbageCollectContainers() error v0.4.1 Oct 17, 2014 Changes in this version + const NetworkContainerImage + const RunOnceManifestDelay + const RunOnceMaxRetries + const RunOnceRetryDelay + const RunOnceRetryDelayBackoff + func GetPodFullName(pod *Pod) string + func ListenAndServeKubeletServer(host HostInterface, updates chan<- interface{}, address net.IP, port uint, ...) + func ResolvePort(portReference util.IntOrString, container *api.Container) (int, error) + func ValidatePod(pod *Pod) (errors []error) + type CadvisorInterface interface + ContainerInfo func(name string, req *info.ContainerInfoRequest) (*info.ContainerInfo, error) + MachineInfo func() (*info.MachineInfo, error) + type FlushWriter struct + func (fw *FlushWriter) Write(p []byte) (n int, err error) + type HostInterface interface + 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) + 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 NewIntegrationTestKubelet(hn string, rd string, dc dockertools.DockerInterface) *Kubelet + func NewMainKubelet(hn string, dc dockertools.DockerInterface, ec tools.EtcdClient, rd string, ...) *Kubelet + func (kl *Kubelet) GetCadvisorClient() CadvisorInterface + func (kl *Kubelet) GetContainerInfo(podFullName, uuid, containerName string, req *info.ContainerInfoRequest) (*info.ContainerInfo, error) + func (kl *Kubelet) GetKubeletContainerLogs(podFullName, containerName, tail string, follow bool, stdout, stderr io.Writer) error + func (kl *Kubelet) GetMachineInfo() (*info.MachineInfo, error) + func (kl *Kubelet) GetPodInfo(podFullName, uuid string) (api.PodInfo, error) + func (kl *Kubelet) GetRootInfo(req *info.ContainerInfoRequest) (*info.ContainerInfo, error) + func (kl *Kubelet) LogEvent(event *api.Event) 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 []Pod) error + type Pod struct + Manifest api.ContainerManifest + Name string + Namespace string + type PodOperation int + const ADD + const REMOVE + const SET + const UPDATE + type PodUpdate struct + Op PodOperation + Pods []Pod + type RunPodResult struct + Err error + Pod *Pod + type Server struct + func NewServer(host HostInterface, updates chan<- interface{}, enableDebuggingHandlers bool) Server + func (s *Server) InstallDebuggingHandlers() + func (s *Server) InstallDefaultHandlers() + func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request) + type SyncHandler interface + SyncPods func([]Pod) error
Go to main page