executor

Documentation

Index

• type ScaleIOExecutor
  • func NewScaleIOExecutor(cfg *config.Config) *ScaleIOExecutor
  • func (e *ScaleIOExecutor) Start() <-chan struct{}

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