scheduler

Documentation

Index

• Variables
• func IsNodeAnMDMNode(node *types.ScaleIONode) bool
• type ScaleIOScheduler
  • func NewScaleIOScheduler(cfg *config.Config) *ScaleIOScheduler
  • func (s *ScaleIOScheduler) Start() <-chan struct{}
  • func (s *ScaleIOScheduler) Stop()

Variables

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

func (s *ScaleIOScheduler) Stop()

Stop the scheduler and all internal channels