executor

Documentation

Overview

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

Index

• type Config
• 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) 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         *kubelet.Kubelet
	Updates         chan<- interface{}
	SourceName      string
	APIClient       *client.Client
	Watch           watch.Interface
	Docker          dockertools.DockerInterface
	ShutdownAlert   func()
	SuicideTimeout  time.Duration
	KubeletFinished <-chan struct{}
}

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 with 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) 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.

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.