Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 5, 2015

Changes in this version

+ type Config struct

+ APIClient *client.Client

+ Docker dockertools.DockerInterface

+ Kubelet *kubelet.Kubelet

+ KubeletFinished <-chan struct{}

+ ShutdownAlert func()

+ SourceName string

+ SuicideTimeout time.Duration

+ Updates chan<- interface{}

+ Watch watch.Interface

type KubernetesExecutor

+ func (k *KubernetesExecutor) Done() <-chan struct{}

+ func (k *KubernetesExecutor) Init(driver bindings.ExecutorDriver)

v0.4.2

Apr 1, 2015

v0.4.1

Mar 18, 2015

v0.4.0

Mar 12, 2015

Changes in this version

+ func KillKubeletContainers(dockerClient dockertools.DockerInterface)

+ type KubernetesExecutor struct

+ func New(kl *kubelet.Kubelet, ch chan<- interface{}, ns string, cl *client.Client, ...) *KubernetesExecutor

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

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

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

+ 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)