scheduler

Documentation

Index

• type BinPackScheduler
  • func NewBinPackScheduler(registry *TaskRegistry) *BinPackScheduler
  • func (s *BinPackScheduler) MatchOffers(offers []*mesos.Offer, lrpAuctions []auctiontypes.LRPAuction, ...) map[string]*OfferMatch
• type DiegoScheduler
  • func InitializeScheduler() (*DiegoScheduler, *sched.MesosSchedulerDriver)
  • func NewDiegoScheduler(exec *mesos.ExecutorInfo) *DiegoScheduler
  • func (s *DiegoScheduler) Disconnected(sched.SchedulerDriver)
  • func (s *DiegoScheduler) Error(_ sched.SchedulerDriver, err string)
  • func (s *DiegoScheduler) ExecutorLost(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, code int)
  • func (s *DiegoScheduler) FrameworkMessage(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, msg string)
  • func (s *DiegoScheduler) HoldOffers()
  • func (s *DiegoScheduler) OfferRescinded(_ sched.SchedulerDriver, oid *mesos.OfferID)
  • func (s *DiegoScheduler) Registered(driver sched.SchedulerDriver, frameworkId *mesos.FrameworkID, ...)
  • func (s *DiegoScheduler) Reregistered(driver sched.SchedulerDriver, masterInfo *mesos.MasterInfo)
  • func (s *DiegoScheduler) ResourceOffers(driver sched.SchedulerDriver, offers []*mesos.Offer)
  • func (s *DiegoScheduler) Schedule(lrpAuctions []auctiontypes.LRPAuction, taskAuctions []auctiontypes.TaskAuction) auctiontypes.AuctionResults
  • func (s *DiegoScheduler) SlaveLost(_ sched.SchedulerDriver, sid *mesos.SlaveID)
  • func (s *DiegoScheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus)
• type OfferMatch
• type SchedulerInterface
• type SpreadScheduler
  • func NewSpreadScheduler(registry *TaskRegistry) *SpreadScheduler
  • func (s *SpreadScheduler) MatchOffers(offers []*mesos.Offer, lrpAuctions []auctiontypes.LRPAuction, ...) map[string]*OfferMatch
• type TaskRegistry
  • func NewTaskRegistry() *TaskRegistry
  • func (r *TaskRegistry) AddLrp(slaveId string, guid string, index int32, state mesos.TaskState)
  • func (r *TaskRegistry) AddTask(slaveId string, guid string, state mesos.TaskState)
  • func (r *TaskRegistry) HasLrpOrTask(slaveId string) bool
  • func (r *TaskRegistry) LrpAndTaskCount(slaveId string) int
  • func (r *TaskRegistry) LrpCount(slaveId string) int
  • func (r *TaskRegistry) LrpInstanceCount(slaveId string, lrpGuid string) int
  • func (r *TaskRegistry) RemoveLrp(slaveId string, guid string, index int32)
  • func (r *TaskRegistry) RemoveTask(slaveId string, guid string)

Types

type BinPackScheduler

type BinPackScheduler struct {
	// contains filtered or unexported fields
}

func NewBinPackScheduler

func NewBinPackScheduler(registry *TaskRegistry) *BinPackScheduler

//////////////////////////

func (*BinPackScheduler) MatchOffers

func (s *BinPackScheduler) MatchOffers(offers []*mesos.Offer, lrpAuctions []auctiontypes.LRPAuction, taskAuctions []auctiontypes.TaskAuction) map[string]*OfferMatch

type DiegoScheduler

type DiegoScheduler struct {
	// contains filtered or unexported fields
}

func InitializeScheduler

func InitializeScheduler() (*DiegoScheduler, *sched.MesosSchedulerDriver)

func NewDiegoScheduler

func NewDiegoScheduler(exec *mesos.ExecutorInfo) *DiegoScheduler

func (*DiegoScheduler) Disconnected

func (s *DiegoScheduler) Disconnected(sched.SchedulerDriver)

func (*DiegoScheduler) Error

func (s *DiegoScheduler) Error(_ sched.SchedulerDriver, err string)

func (*DiegoScheduler) ExecutorLost

func (s *DiegoScheduler) ExecutorLost(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, code int)

func (*DiegoScheduler) FrameworkMessage

func (s *DiegoScheduler) FrameworkMessage(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, msg string)

func (*DiegoScheduler) HoldOffers

func (s *DiegoScheduler) HoldOffers()

func (*DiegoScheduler) OfferRescinded

func (s *DiegoScheduler) OfferRescinded(_ sched.SchedulerDriver, oid *mesos.OfferID)

func (*DiegoScheduler) Registered

func (s *DiegoScheduler) Registered(driver sched.SchedulerDriver, frameworkId *mesos.FrameworkID, masterInfo *mesos.MasterInfo)

func (*DiegoScheduler) Reregistered

func (s *DiegoScheduler) Reregistered(driver sched.SchedulerDriver, masterInfo *mesos.MasterInfo)

func (*DiegoScheduler) ResourceOffers

func (s *DiegoScheduler) ResourceOffers(driver sched.SchedulerDriver, offers []*mesos.Offer)

func (*DiegoScheduler) Schedule

func (s *DiegoScheduler) Schedule(lrpAuctions []auctiontypes.LRPAuction, taskAuctions []auctiontypes.TaskAuction) auctiontypes.AuctionResults

func (*DiegoScheduler) SlaveLost

func (s *DiegoScheduler) SlaveLost(_ sched.SchedulerDriver, sid *mesos.SlaveID)

func (*DiegoScheduler) StatusUpdate

func (s *DiegoScheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus)

type OfferMatch

type OfferMatch struct {
	Offers       []*mesos.Offer
	LrpAuctions  []auctiontypes.LRPAuction
	TaskAuctions []auctiontypes.TaskAuction
}

type SchedulerInterface

type SchedulerInterface interface {
	MatchOffers(offers []*mesos.Offer,
		lrpAuctions []auctiontypes.LRPAuction, taskAuctions []auctiontypes.TaskAuction) map[string]*OfferMatch
}

type SpreadScheduler

type SpreadScheduler struct {
	// contains filtered or unexported fields
}

func NewSpreadScheduler

func NewSpreadScheduler(registry *TaskRegistry) *SpreadScheduler

////////////////////

func (*SpreadScheduler) MatchOffers

func (s *SpreadScheduler) MatchOffers(offers []*mesos.Offer, lrpAuctions []auctiontypes.LRPAuction, taskAuctions []auctiontypes.TaskAuction) map[string]*OfferMatch

type TaskRegistry

type TaskRegistry struct {
	// contains filtered or unexported fields
}

func NewTaskRegistry

func NewTaskRegistry() *TaskRegistry

func (*TaskRegistry) AddLrp

func (r *TaskRegistry) AddLrp(slaveId string, guid string, index int32, state mesos.TaskState)

func (*TaskRegistry) AddTask

func (r *TaskRegistry) AddTask(slaveId string, guid string, state mesos.TaskState)

func (*TaskRegistry) HasLrpOrTask

func (r *TaskRegistry) HasLrpOrTask(slaveId string) bool

func (*TaskRegistry) LrpAndTaskCount

func (r *TaskRegistry) LrpAndTaskCount(slaveId string) int

func (*TaskRegistry) LrpCount

func (r *TaskRegistry) LrpCount(slaveId string) int

func (*TaskRegistry) LrpInstanceCount

func (r *TaskRegistry) LrpInstanceCount(slaveId string, lrpGuid string) int

func (*TaskRegistry) RemoveLrp

func (r *TaskRegistry) RemoveLrp(slaveId string, guid string, index int32)

func (*TaskRegistry) RemoveTask

func (r *TaskRegistry) RemoveTask(slaveId string, guid string)