Versions in this module Expand all Collapse all v0 v0.20.0 Jun 24, 2015 Changes in this version + type Config struct + APIClient *client.Client + Docker dockertools.DockerInterface + ExitFunc func(int) + Kubelet KubeletInterface + KubeletFinished <-chan struct{} + PodStatusFunc func(KubeletInterface, *api.Pod) (*api.PodStatus, error) + ShutdownAlert func() + SourceName string + StaticPodsConfigPath string + SuicideTimeout time.Duration + Updates chan<- interface{} + Watch watch.Interface + type KubeletInterface interface + GetHostIP func() (net.IP, error) + type KubernetesExecutor struct + func New(config Config) *KubernetesExecutor + func (k *KubernetesExecutor) Disconnected(driver bindings.ExecutorDriver) + func (k *KubernetesExecutor) Done() <-chan struct{} + func (k *KubernetesExecutor) Error(driver bindings.ExecutorDriver, message string) + func (k *KubernetesExecutor) FrameworkMessage(driver bindings.ExecutorDriver, message string) + func (k *KubernetesExecutor) Init(driver bindings.ExecutorDriver) + func (k *KubernetesExecutor) InitializeStaticPodsSource(sourceFactory func()) + func (k *KubernetesExecutor) KillTask(driver bindings.ExecutorDriver, taskId *mesos.TaskID) + func (k *KubernetesExecutor) LaunchTask(driver bindings.ExecutorDriver, taskInfo *mesos.TaskInfo) + func (k *KubernetesExecutor) Registered(driver bindings.ExecutorDriver, executorInfo *mesos.ExecutorInfo, ...) + func (k *KubernetesExecutor) Reregistered(driver bindings.ExecutorDriver, slaveInfo *mesos.SlaveInfo) + func (k *KubernetesExecutor) Shutdown(driver bindings.ExecutorDriver)