Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( //ErrMdmSelectionFailed Unable to select an MDM node from available Agents ErrMdmSelectionFailed = errors.New("Unable to select an MDM node from available Agents") )
Functions ¶
func IsNodeAnMDMNode ¶
func IsNodeAnMDMNode(node *types.ScaleIONode) bool
IsNodeAnMDMNode returns true is node is an MDM node
Types ¶
type ScaleIOScheduler ¶
type ScaleIOScheduler struct {
Config *config.Config
Store *kvstore.KvStore
Framework *mesos.FrameworkInfo
Server *server.RestServer
Client *client.Client
Events chan *sched.Event
DoneChan chan struct{}
}
ScaleIOScheduler represents a Mesos scheduler
func NewScaleIOScheduler ¶
func NewScaleIOScheduler(cfg *config.Config) *ScaleIOScheduler
NewScaleIOScheduler returns a pointer to new Scheduler
func (*ScaleIOScheduler) Start ¶
func (s *ScaleIOScheduler) Start() <-chan struct{}
Start starts the scheduler and subscribes to event stream returns a channel to wait for completion.
func (*ScaleIOScheduler) Stop ¶ added in v0.3.0
func (s *ScaleIOScheduler) Stop()
Stop the scheduler and all internal channels
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.