Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( //ErrFoundSelfFailed found myself failed ErrFoundSelfFailed = errors.New("Failed to locate self node") )
Functions ¶
func RunExecutor ¶ added in v0.2.0
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.