executor

Documentation

Index

• Variables
• func RunExecutor(cfg *config.Config, getstate common.RetrieveState) error
• type ScaleIOExecutor
  • func NewScaleIOExecutor(cfg *config.Config) *ScaleIOExecutor
  • func (e *ScaleIOExecutor) Start() <-chan struct{}

Variables

var (
	//ErrFoundSelfFailed found myself failed
	ErrFoundSelfFailed = errors.New("Failed to locate self node")
)

Functions

func RunExecutor

func RunExecutor(cfg *config.Config, getstate common.RetrieveState) error

RunExecutor starts the executor

Types

type ScaleIOExecutor

type ScaleIOExecutor struct {
	Config *config.Config

	ExecutorID  *mesos.ExecutorID
	FrameworkID *mesos.FrameworkID

	Client *client.Client

	Events   chan *exec.Event
	DoneChan chan struct{}

	ObservedFailures int
}

ScaleIOExecutor is the representation for an ScaleIO Executor process

func NewScaleIOExecutor

func NewScaleIOExecutor(cfg *config.Config) *ScaleIOExecutor

NewScaleIOExecutor creates a ScaleIO executor object

func (*ScaleIOExecutor) Start

func (e *ScaleIOExecutor) Start() <-chan struct{}

Start kicks off the executor workflow