executor

Documentation

Index

• func New(launchTimeout time.Duration) executor.Executor
• type EtcdParams
• type Executor
  • func (e *Executor) Disconnected(_ executor.ExecutorDriver)
  • func (e *Executor) Error(_ executor.ExecutorDriver, err string)
  • func (e *Executor) FrameworkMessage(driver executor.ExecutorDriver, msg string)
  • func (e *Executor) KillTask(driver executor.ExecutorDriver, t *mesos.TaskID)
  • func (e *Executor) LaunchTask(driver executor.ExecutorDriver, taskInfo *mesos.TaskInfo)
  • func (e *Executor) Registered(_ executor.ExecutorDriver, _ *mesos.ExecutorInfo, _ *mesos.FrameworkInfo, ...)
  • func (e *Executor) Reregistered(_ executor.ExecutorDriver, si *mesos.SlaveInfo)
  • func (e *Executor) Shutdown(_ executor.ExecutorDriver)

Functions

func New

func New(launchTimeout time.Duration) executor.Executor

New returns an an implementation of an etcd Mesos executor that runs the given command when tasks are launched.

Types

type EtcdParams

type EtcdParams struct {
	config.Node
	Cluster string
}

type Executor

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

func (*Executor) Disconnected

func (e *Executor) Disconnected(_ executor.ExecutorDriver)

func (*Executor) Error

func (e *Executor) Error(_ executor.ExecutorDriver, err string)

func (*Executor) FrameworkMessage

func (e *Executor) FrameworkMessage(
	driver executor.ExecutorDriver,
	msg string,
)

func (*Executor) KillTask

func (e *Executor) KillTask(driver executor.ExecutorDriver, t *mesos.TaskID)

func (*Executor) LaunchTask

func (e *Executor) LaunchTask(
	driver executor.ExecutorDriver,
	taskInfo *mesos.TaskInfo,
)

func (*Executor) Registered

func (e *Executor) Registered(
	_ executor.ExecutorDriver,
	_ *mesos.ExecutorInfo,
	_ *mesos.FrameworkInfo,
	si *mesos.SlaveInfo,
)

func (*Executor) Reregistered

func (e *Executor) Reregistered(
	_ executor.ExecutorDriver,
	si *mesos.SlaveInfo,
)

func (*Executor) Shutdown

func (e *Executor) Shutdown(_ executor.ExecutorDriver)