executor

Jan 5, 2015

Changes in this version

type HostInterface

+ GetBoundPods func() ([]api.BoundPod, error)

Nov 28, 2014

Changes in this version

+ type FlushWriter struct

+ func (fw *FlushWriter) Write(p []byte) (n int, err error)

type HostInterface

+ GetKubeletContainerLogs func(podFullName, containerName, tail string, follow bool, stdout, stderr io.Writer) error

type Server

+ func (s *Server) InstallDebuggingHandlers()

Nov 10, 2014

Changes in this version

+ func ListenAndServeKubeletServer(host HostInterface, updates chan<- interface{}, address string, port uint, ...)

+ type HostInterface interface

+ GetContainerInfo func(podFullName, uuid, containerName string, req *info.ContainerInfoRequest) (*info.ContainerInfo, error)

+ GetMachineInfo func() (*info.MachineInfo, error)

+ GetPodInfo func(name, uuid string) (api.PodInfo, error)

+ GetRootInfo func(req *info.ContainerInfoRequest) (*info.ContainerInfo, error)

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

+ type KubernetesExecutor struct

+ func New(driver mesos.ExecutorDriver, kl *kubelet.Kubelet, ch chan<- interface{}, ...) *KubernetesExecutor

+ func (k *KubernetesExecutor) Disconnected(driver mesos.ExecutorDriver)

+ func (k *KubernetesExecutor) Error(driver mesos.ExecutorDriver, message string)

+ func (k *KubernetesExecutor) FrameworkMessage(driver mesos.ExecutorDriver, message string)

+ func (k *KubernetesExecutor) KillTask(driver mesos.ExecutorDriver, taskId *mesos.TaskID)

+ func (k *KubernetesExecutor) LaunchTask(driver mesos.ExecutorDriver, taskInfo *mesos.TaskInfo)

+ func (k *KubernetesExecutor) Registered(driver mesos.ExecutorDriver, executorInfo *mesos.ExecutorInfo, ...)

+ func (k *KubernetesExecutor) Reregistered(driver mesos.ExecutorDriver, slaveInfo *mesos.SlaveInfo)

+ func (k *KubernetesExecutor) Shutdown(driver mesos.ExecutorDriver)

+ type Server struct

+ func NewServer(host HostInterface, updates chan<- interface{}, ns string) Server

+ func (s *Server) InstallDefaultHandlers()

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