scheduler

Jun 26, 2015

Changes in this version

+ type CredentialHandler struct

+ func (h *CredentialHandler) Handle(callbacks ...callback.Interface) error

+ type DriverConfig struct

+ BindingAddress net.IP

+ BindingPort uint16

+ Credential *mesos.Credential

+ Framework *mesos.FrameworkInfo

+ HostnameOverride string

+ Master string

+ NewMessenger func() (messenger.Messenger, error)

+ Scheduler Scheduler

+ WithAuthContext func(context.Context) context.Context

+ type MesosSchedulerDriver struct

+ FrameworkInfo *mesos.FrameworkInfo

+ MasterPid *upid.UPID

+ Scheduler Scheduler

+ func NewMesosSchedulerDriver(config DriverConfig) (initializedDriver *MesosSchedulerDriver, err error)

+ func (driver *MesosSchedulerDriver) Abort() (stat mesos.Status, err error)

+ func (driver *MesosSchedulerDriver) Connected() bool

+ func (driver *MesosSchedulerDriver) DeclineOffer(offerId *mesos.OfferID, filters *mesos.Filters) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) Join() (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) KillTask(taskId *mesos.TaskID) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) LaunchTasks(offerIds []*mesos.OfferID, tasks []*mesos.TaskInfo, filters *mesos.Filters) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) ReconcileTasks(statuses []*mesos.TaskStatus) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) RequestResources(requests []*mesos.Request) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) ReviveOffers() (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) Run() (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) SendFrameworkMessage(executorId *mesos.ExecutorID, slaveId *mesos.SlaveID, data string) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) Start() (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) Status() mesos.Status

+ func (driver *MesosSchedulerDriver) Stop(failover bool) (mesos.Status, error)

+ func (driver *MesosSchedulerDriver) Stopped() bool

+ type MockScheduler struct

+ func NewMockScheduler() *MockScheduler

+ func (sched *MockScheduler) Disconnected(SchedulerDriver)

+ func (sched *MockScheduler) Error(d SchedulerDriver, msg string)

+ func (sched *MockScheduler) ExecutorLost(SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)

+ func (sched *MockScheduler) FrameworkMessage(SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, string)

+ func (sched *MockScheduler) OfferRescinded(SchedulerDriver, *mesos.OfferID)

+ func (sched *MockScheduler) Registered(SchedulerDriver, *mesos.FrameworkID, *mesos.MasterInfo)

+ func (sched *MockScheduler) Reregistered(SchedulerDriver, *mesos.MasterInfo)

+ func (sched *MockScheduler) ResourceOffers(SchedulerDriver, []*mesos.Offer)

+ func (sched *MockScheduler) SlaveLost(SchedulerDriver, *mesos.SlaveID)

+ func (sched *MockScheduler) StatusUpdate(SchedulerDriver, *mesos.TaskStatus)

+ type Scheduler interface

+ Disconnected func(SchedulerDriver)

+ Error func(SchedulerDriver, string)

+ ExecutorLost func(SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)

+ FrameworkMessage func(SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, string)

+ OfferRescinded func(SchedulerDriver, *mesos.OfferID)

+ Registered func(SchedulerDriver, *mesos.FrameworkID, *mesos.MasterInfo)

+ Reregistered func(SchedulerDriver, *mesos.MasterInfo)

+ ResourceOffers func(SchedulerDriver, []*mesos.Offer)

+ SlaveLost func(SchedulerDriver, *mesos.SlaveID)

+ StatusUpdate func(SchedulerDriver, *mesos.TaskStatus)

+ type SchedulerDriver interface

+ Abort func() (mesos.Status, error)

+ DeclineOffer func(offerID *mesos.OfferID, filters *mesos.Filters) (mesos.Status, error)

+ Join func() (mesos.Status, error)

+ KillTask func(taskID *mesos.TaskID) (mesos.Status, error)

+ LaunchTasks func(offerIDs []*mesos.OfferID, tasks []*mesos.TaskInfo, filters *mesos.Filters) (mesos.Status, error)

+ ReconcileTasks func(statuses []*mesos.TaskStatus) (mesos.Status, error)

+ RequestResources func(requests []*mesos.Request) (mesos.Status, error)

+ ReviveOffers func() (mesos.Status, error)

+ Run func() (mesos.Status, error)

+ SendFrameworkMessage func(executorID *mesos.ExecutorID, slaveID *mesos.SlaveID, data string) (mesos.Status, error)

+ Start func() (mesos.Status, error)

+ Stop func(failover bool) (mesos.Status, error)