scheduler

Documentation

Index

• Variables
• func NewMesosScheduler(ctx context.Context, listenAddr string, mesosMasterAddr string, ...) (*sched.MesosSchedulerDriver, error)
• type SchedulerSettings
• type VDCScheduler
  • func (sched *VDCScheduler) CheckForCrashedNodes(offers []*mesos.Offer, ctx context.Context) error
  • func (sched *VDCScheduler) DeclineUnusedOffers(driver sched.SchedulerDriver, offers []*mesos.Offer, ...)
  • func (sched *VDCScheduler) Disconnected(sched.SchedulerDriver)
  • func (sched *VDCScheduler) Error(_ sched.SchedulerDriver, err string)
  • func (sched *VDCScheduler) ExecutorLost(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, code int)
  • func (sched *VDCScheduler) FrameworkMessage(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, msg string)
  • func (sched *VDCScheduler) InstancesQueued(driver sched.SchedulerDriver, offers []*mesos.Offer, ctx context.Context) error
  • func (sched *VDCScheduler) InstancesRelaunching(driver sched.SchedulerDriver, offers []*mesos.Offer, ctx context.Context, ...) error
  • func (sched *VDCScheduler) LaunchTasks(driver sched.SchedulerDriver, tasks []*mesos.TaskInfo, ...) error
  • func (sched *VDCScheduler) NewExecutor(hypervisorName string) *mesos.ExecutorInfo
  • func (sched *VDCScheduler) NewTask(i *model.Instance, slaveID *mesos.SlaveID, ctx context.Context, ...) *mesos.TaskInfo
  • func (sched *VDCScheduler) OfferRescinded(_ sched.SchedulerDriver, oid *mesos.OfferID)
  • func (sched *VDCScheduler) Registered(driver sched.SchedulerDriver, frameworkId *mesos.FrameworkID, ...)
  • func (sched *VDCScheduler) Reregistered(driver sched.SchedulerDriver, masterInfo *mesos.MasterInfo)
  • func (sched *VDCScheduler) ResourceOffers(driver sched.SchedulerDriver, offers []*mesos.Offer)
  • func (sched *VDCScheduler) SlaveLost(_ sched.SchedulerDriver, sid *mesos.SlaveID)
  • func (sched *VDCScheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus)

Variables

var ExecutorPath string

Functions

func NewMesosScheduler

func NewMesosScheduler(ctx context.Context, listenAddr string, mesosMasterAddr string, zkAddr backend.ZkEndpoint, settings SchedulerSettings) (*sched.MesosSchedulerDriver, error)

Types

type SchedulerSettings

type SchedulerSettings struct {
	Name            string
	ID              string
	FailoverTimeout float64
	ExecutorPath    string
}

type VDCScheduler

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

func (*VDCScheduler) CheckForCrashedNodes

func (sched *VDCScheduler) CheckForCrashedNodes(offers []*mesos.Offer, ctx context.Context) error

func (*VDCScheduler) DeclineUnusedOffers

func (sched *VDCScheduler) DeclineUnusedOffers(driver sched.SchedulerDriver, offers []*mesos.Offer, acceptIDs []*mesos.OfferID)

func (*VDCScheduler) Disconnected

func (sched *VDCScheduler) Disconnected(sched.SchedulerDriver)

func (*VDCScheduler) Error

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

func (*VDCScheduler) ExecutorLost

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

func (*VDCScheduler) FrameworkMessage

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

func (*VDCScheduler) InstancesQueued

func (sched *VDCScheduler) InstancesQueued(driver sched.SchedulerDriver, offers []*mesos.Offer, ctx context.Context) error

func (*VDCScheduler) InstancesRelaunching

func (sched *VDCScheduler) InstancesRelaunching(driver sched.SchedulerDriver, offers []*mesos.Offer, ctx context.Context, relaunchQueued []*model.Instance) error

func (*VDCScheduler) LaunchTasks

func (sched *VDCScheduler) LaunchTasks(driver sched.SchedulerDriver, tasks []*mesos.TaskInfo, acceptIDs []*mesos.OfferID, offers []*mesos.Offer) error

func (*VDCScheduler) NewExecutor

func (sched *VDCScheduler) NewExecutor(hypervisorName string) *mesos.ExecutorInfo

func (*VDCScheduler) NewTask

func (sched *VDCScheduler) NewTask(i *model.Instance, slaveID *mesos.SlaveID, ctx context.Context, executor *mesos.ExecutorInfo) *mesos.TaskInfo

func (*VDCScheduler) OfferRescinded

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

func (*VDCScheduler) Registered

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

func (*VDCScheduler) Reregistered

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

func (*VDCScheduler) ResourceOffers

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

func (*VDCScheduler) SlaveLost

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

func (*VDCScheduler) StatusUpdate

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