Executor

Documentation

Index

• Variables
• func GetLocalIP() string
• func Run(SE StatefulExecutor)
• type StatefulExecutor
• type WorkloadExecutor
  • func NewWorkloadExecutor() *WorkloadExecutor
  • func (exec *WorkloadExecutor) Disconnected(exec.ExecutorDriver)
  • func (exec *WorkloadExecutor) Error(driver exec.ExecutorDriver, err string)
  • func (exec *WorkloadExecutor) FrameworkMessage(driver exec.ExecutorDriver, msg string)
  • func (exec *WorkloadExecutor) KillTask(driver exec.ExecutorDriver, taskID *mesos.TaskID)
  • func (exec *WorkloadExecutor) LaunchTask(driver exec.ExecutorDriver, taskInfo *mesos.TaskInfo)
  • func (exec *WorkloadExecutor) Registered(driver exec.ExecutorDriver, execInfo *mesos.ExecutorInfo, ...)
  • func (exec *WorkloadExecutor) Reregistered(driver exec.ExecutorDriver, slaveInfo *mesos.SlaveInfo)
  • func (exec *WorkloadExecutor) Shutdown(exec.ExecutorDriver)

Variables

var Image = flag.String("Image", "image-name", "Image of the worklaod Proc to be downloaded")

var WorkloadLogger *log.Logger

WorkloadLogger A global Logger pointer for the executor all the TaskMon will write to the same logger

Functions

func GetLocalIP

func GetLocalIP() string

GetLocalIP A function to look up the exposed local IP such that the executor can bind to

func Run

func Run(SE StatefulExecutor)

Types

type StatefulExecutor

type StatefulExecutor interface {
	Config(*typ.Task)
	TaskStarted(*typ.Task)
	Cleanup(*typ.Task)
	UpdateConfig(*typ.Task)
}

An interface for Custom Executor

type WorkloadExecutor

type WorkloadExecutor struct {
	CustomExecutor StatefulExecutor

	HostIP string
	// contains filtered or unexported fields
}

WorkloadExecutor Basic strucutre for the executor

func NewWorkloadExecutor

func NewWorkloadExecutor() *WorkloadExecutor

NewWorkLoadExecutor Constructor for the executor structure

func (*WorkloadExecutor) Disconnected

func (exec *WorkloadExecutor) Disconnected(exec.ExecutorDriver)

Disconnected Call back for disconnected

func (*WorkloadExecutor) Error

func (exec *WorkloadExecutor) Error(driver exec.ExecutorDriver, err string)

Error not implemented yet

func (*WorkloadExecutor) FrameworkMessage

func (exec *WorkloadExecutor) FrameworkMessage(driver exec.ExecutorDriver, msg string)

FrameworkMessage Any message sent from the scheduelr , not sued for this project

func (*WorkloadExecutor) KillTask

func (exec *WorkloadExecutor) KillTask(driver exec.ExecutorDriver, taskID *mesos.TaskID)

KillTask When a running task needs to be killed should come from the Agent/Slave its a call back implementation

func (*WorkloadExecutor) LaunchTask

func (exec *WorkloadExecutor) LaunchTask(driver exec.ExecutorDriver, taskInfo *mesos.TaskInfo)

LaunchTask Call back implementation when a Launch task request comes from Slave/Agent

func (*WorkloadExecutor) Registered

func (exec *WorkloadExecutor) Registered(driver exec.ExecutorDriver, execInfo *mesos.ExecutorInfo, fwinfo *mesos.FrameworkInfo, slaveInfo *mesos.SlaveInfo)

Registered Call back for registered driver

func (*WorkloadExecutor) Reregistered

func (exec *WorkloadExecutor) Reregistered(driver exec.ExecutorDriver, slaveInfo *mesos.SlaveInfo)

Reregistered call back for the re-registered driver

func (*WorkloadExecutor) Shutdown

func (exec *WorkloadExecutor) Shutdown(exec.ExecutorDriver)

Shutdown Not implemented yet