executor

Documentation

Overview

Package executor includes a mesos executor, which contains a kubelet as its member to manage containers.

Index

• type Config
• type KubeletInterface
• type KubernetesExecutor
  • 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)

Types

type Config

type Config struct {
	Kubelet              KubeletInterface
	Updates              chan<- interface{} // to send pod config updates to the kubelet
	SourceName           string
	APIClient            *client.Client
	Watch                watch.Interface
	Docker               dockertools.DockerInterface
	ShutdownAlert        func()
	SuicideTimeout       time.Duration
	KubeletFinished      <-chan struct{} // signals that kubelet Run() died
	ExitFunc             func(int)
	PodStatusFunc        func(KubeletInterface, *api.Pod) (*api.PodStatus, error)
	StaticPodsConfigPath string
}

type KubeletInterface

type KubeletInterface interface {
	GetHostIP() (net.IP, error)
}

KubeletInterface consists of the kubelet.Kubelet API's that we actually use

type KubernetesExecutor

type KubernetesExecutor struct {
	// contains filtered or unexported fields
}

KubernetesExecutor is an mesos executor that runs pods in a minion machine.

func New

func New(config Config) *KubernetesExecutor

New creates a new kubernetes executor.

func (*KubernetesExecutor) Disconnected

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

Disconnected is called when the executor is disconnected from the slave.

func (*KubernetesExecutor) Done

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

func (*KubernetesExecutor) Error

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

Error is called when some error happens.

func (*KubernetesExecutor) FrameworkMessage

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

FrameworkMessage is called when the framework sends some message to the executor

func (*KubernetesExecutor) Init

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

func (*KubernetesExecutor) InitializeStaticPodsSource

func (k *KubernetesExecutor) InitializeStaticPodsSource(sourceFactory func())

InitializeStaticPodsSource blocks until initial regstration is complete and then creates a static pod source using the given factory func.

func (*KubernetesExecutor) KillTask

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

KillTask is called when the executor receives a request to kill a task.

func (*KubernetesExecutor) LaunchTask

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

LaunchTask is called when the executor receives a request to launch a task. The happens when the k8sm scheduler has decided to schedule the pod (which corresponds to a Mesos Task) onto the node where this executor is running, but the binding is not recorded in the Kubernetes store yet. This function is invoked to tell the executor to record the binding in the Kubernetes store and start the pod via the Kubelet.

func (*KubernetesExecutor) Registered

func (k *KubernetesExecutor) Registered(driver bindings.ExecutorDriver,
	executorInfo *mesos.ExecutorInfo, frameworkInfo *mesos.FrameworkInfo, slaveInfo *mesos.SlaveInfo)

Registered is called when the executor is successfully registered with the slave.

func (*KubernetesExecutor) Reregistered

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

Reregistered is called when the executor is successfully re-registered with the slave. This can happen when the slave fails over.

func (*KubernetesExecutor) Shutdown

func (k *KubernetesExecutor) Shutdown(driver bindings.ExecutorDriver)

Shutdown is called when the executor receives a shutdown request.