Documentation ¶
Index ¶
- type ErrScheduler
- type ErrorReader
- type MesosScheduler
- func (m *MesosScheduler) Abort() (stat mesosproto.Status, err error)
- func (m *MesosScheduler) AcceptOffers(offerIds []*mesosproto.OfferID, operations []*mesosproto.Offer_Operation, ...) (mesosproto.Status, error)
- func (m *MesosScheduler) DeclineOffer(offerID *mesosproto.OfferID, filters *mesosproto.Filters) (mesosproto.Status, error)
- func (m *MesosScheduler) Disconnected(s scheduler.SchedulerDriver)
- func (m *MesosScheduler) Error(d scheduler.SchedulerDriver, msg string)
- func (m *MesosScheduler) ExecutorLost(sd scheduler.SchedulerDriver, eID *mesosproto.ExecutorID, ...)
- func (m *MesosScheduler) FrameworkMessage(sd scheduler.SchedulerDriver, eID *mesosproto.ExecutorID, ...)
- func (m *MesosScheduler) Join() (mesosproto.Status, error)
- func (m *MesosScheduler) KillTask(id *mesosproto.TaskID) (mesosproto.Status, error)
- func (m *MesosScheduler) LaunchTasks(o []*mesosproto.OfferID, t []*mesosproto.TaskInfo, f *mesosproto.Filters) (mesosproto.Status, error)
- func (m *MesosScheduler) OfferRescinded(s scheduler.SchedulerDriver, o *mesosproto.OfferID)
- func (m *MesosScheduler) ReconcileTasks(ts []*mesosproto.TaskStatus) (mesosproto.Status, error)
- func (m *MesosScheduler) Registered(s scheduler.SchedulerDriver, f *mesosproto.FrameworkID, ...)
- func (m *MesosScheduler) RequestResources(r []*mesosproto.Request) (mesosproto.Status, error)
- func (m *MesosScheduler) Reregistered(s scheduler.SchedulerDriver, info *mesosproto.MasterInfo)
- func (m *MesosScheduler) ResourceOffers(s scheduler.SchedulerDriver, o []*mesosproto.Offer)
- func (m *MesosScheduler) ReviveOffers() (mesosproto.Status, error)
- func (m *MesosScheduler) Run() (mesosproto.Status, error)
- func (m *MesosScheduler) SendFrameworkMessage(eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, s string) (mesosproto.Status, error)
- func (m *MesosScheduler) SlaveLost(s scheduler.SchedulerDriver, sID *mesosproto.SlaveID)
- func (m *MesosScheduler) Start() (mesosproto.Status, error)
- func (m *MesosScheduler) StatusUpdate(s scheduler.SchedulerDriver, ts *mesosproto.TaskStatus)
- func (m *MesosScheduler) Stop(b bool) (mesosproto.Status, error)
- type Scheduler
- type TaskDB
- func (db *TaskDB) Clean() error
- func (db *TaskDB) Close()
- func (db *TaskDB) DeleteTask(id string) error
- func (db *TaskDB) ListNonTerminalTasks() ([]*eremetic.Task, error)
- func (db *TaskDB) PutTask(task *eremetic.Task) error
- func (db *TaskDB) ReadTask(id string) (eremetic.Task, error)
- func (db *TaskDB) ReadUnmaskedTask(id string) (eremetic.Task, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrScheduler ¶
type ErrScheduler struct {
NextError *error
}
ErrScheduler mocks the eremetic scheduler.
func (*ErrScheduler) Kill ¶ added in v0.27.0
func (s *ErrScheduler) Kill(_id string) error
func (*ErrScheduler) ScheduleTask ¶
func (s *ErrScheduler) ScheduleTask(request eremetic.Request) (string, error)
ScheduleTask records any scheduling errors.
type MesosScheduler ¶ added in v0.27.0
type MesosScheduler struct { AbortFn func() (mesosproto.Status, error) AbortFnInvoked bool AcceptOffersFn func([]*mesosproto.OfferID, []*mesosproto.Offer_Operation, *mesosproto.Filters) (mesosproto.Status, error) AcceptOffersFnInvoked bool DeclineOfferFn func(*mesosproto.OfferID, *mesosproto.Filters) (mesosproto.Status, error) DeclineOfferFnInvoked bool JoinFn func() (mesosproto.Status, error) JoinFnInvoked bool KillTaskFn func(*mesosproto.TaskID) (mesosproto.Status, error) KillTaskFnInvoked bool ReconcileTasksFn func([]*mesosproto.TaskStatus) (mesosproto.Status, error) ReconcileTasksFnInvoked bool RequestResourcesFn func([]*mesosproto.Request) (mesosproto.Status, error) RequestResourcesFnInvoked bool ReviveOffersFn func() (mesosproto.Status, error) ReviveOffersFnInvoked bool RunFn func() (mesosproto.Status, error) RunFnInvoked bool StartFn func() (mesosproto.Status, error) StartFnInvoked bool StopFn func(bool) (mesosproto.Status, error) StopFnInvoked bool SendFrameworkMessageFn func(*mesosproto.ExecutorID, *mesosproto.SlaveID, string) (mesosproto.Status, error) SendFrameworkMessageFnInvoked bool LaunchTasksFn func([]*mesosproto.OfferID, []*mesosproto.TaskInfo, *mesosproto.Filters) (mesosproto.Status, error) LaunchTasksFnInvoked bool RegisteredFn func(scheduler.SchedulerDriver, *mesosproto.FrameworkID, *mesosproto.MasterInfo) RegisteredFnInvoked bool ReregisteredFn func(scheduler.SchedulerDriver, *mesosproto.MasterInfo) ReregisteredFnInvoked bool DisconnectedFn func(scheduler.SchedulerDriver) DisconnectedFnInvoked bool ResourceOffersFn func(scheduler.SchedulerDriver, []*mesosproto.Offer) ResourceOffersFnInvoked bool OfferRescindedFn func(scheduler.SchedulerDriver, *mesosproto.OfferID) OfferRescindedFnInvoked bool StatusUpdateFn func(scheduler.SchedulerDriver, *mesosproto.TaskStatus) StatusUpdateFnInvoked bool FrameworkMessageFn func(scheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, string) FrameworkMessageFnInvoked bool SlaveLostFn func(scheduler.SchedulerDriver, *mesosproto.SlaveID) SlaveLostFnInvoked bool ExecutorLostFn func(scheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, int) ExecutorLostFnInvoked bool ErrorFn func(scheduler.SchedulerDriver, string) ErrorFnInvoked bool }
MesosScheduler implements a mocked mesos scheduler iterface for testing
func NewMesosScheduler ¶ added in v0.27.0
func NewMesosScheduler() *MesosScheduler
NewMesosScheduler returns a new mocked mesos scheduler
func (*MesosScheduler) Abort ¶ added in v0.27.0
func (m *MesosScheduler) Abort() (stat mesosproto.Status, err error)
func (*MesosScheduler) AcceptOffers ¶ added in v0.27.0
func (m *MesosScheduler) AcceptOffers(offerIds []*mesosproto.OfferID, operations []*mesosproto.Offer_Operation, filters *mesosproto.Filters) (mesosproto.Status, error)
func (*MesosScheduler) DeclineOffer ¶ added in v0.27.0
func (m *MesosScheduler) DeclineOffer(offerID *mesosproto.OfferID, filters *mesosproto.Filters) (mesosproto.Status, error)
func (*MesosScheduler) Disconnected ¶ added in v0.27.0
func (m *MesosScheduler) Disconnected(s scheduler.SchedulerDriver)
func (*MesosScheduler) Error ¶ added in v0.27.0
func (m *MesosScheduler) Error(d scheduler.SchedulerDriver, msg string)
func (*MesosScheduler) ExecutorLost ¶ added in v0.27.0
func (m *MesosScheduler) ExecutorLost(sd scheduler.SchedulerDriver, eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, i int)
func (*MesosScheduler) FrameworkMessage ¶ added in v0.27.0
func (m *MesosScheduler) FrameworkMessage(sd scheduler.SchedulerDriver, eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, s string)
func (*MesosScheduler) Join ¶ added in v0.27.0
func (m *MesosScheduler) Join() (mesosproto.Status, error)
func (*MesosScheduler) KillTask ¶ added in v0.27.0
func (m *MesosScheduler) KillTask(id *mesosproto.TaskID) (mesosproto.Status, error)
func (*MesosScheduler) LaunchTasks ¶ added in v0.27.0
func (m *MesosScheduler) LaunchTasks(o []*mesosproto.OfferID, t []*mesosproto.TaskInfo, f *mesosproto.Filters) (mesosproto.Status, error)
func (*MesosScheduler) OfferRescinded ¶ added in v0.27.0
func (m *MesosScheduler) OfferRescinded(s scheduler.SchedulerDriver, o *mesosproto.OfferID)
func (*MesosScheduler) ReconcileTasks ¶ added in v0.27.0
func (m *MesosScheduler) ReconcileTasks(ts []*mesosproto.TaskStatus) (mesosproto.Status, error)
func (*MesosScheduler) Registered ¶ added in v0.27.0
func (m *MesosScheduler) Registered(s scheduler.SchedulerDriver, f *mesosproto.FrameworkID, minfo *mesosproto.MasterInfo)
func (*MesosScheduler) RequestResources ¶ added in v0.27.0
func (m *MesosScheduler) RequestResources(r []*mesosproto.Request) (mesosproto.Status, error)
func (*MesosScheduler) Reregistered ¶ added in v0.27.0
func (m *MesosScheduler) Reregistered(s scheduler.SchedulerDriver, info *mesosproto.MasterInfo)
func (*MesosScheduler) ResourceOffers ¶ added in v0.27.0
func (m *MesosScheduler) ResourceOffers(s scheduler.SchedulerDriver, o []*mesosproto.Offer)
func (*MesosScheduler) ReviveOffers ¶ added in v0.27.0
func (m *MesosScheduler) ReviveOffers() (mesosproto.Status, error)
func (*MesosScheduler) Run ¶ added in v0.27.0
func (m *MesosScheduler) Run() (mesosproto.Status, error)
func (*MesosScheduler) SendFrameworkMessage ¶ added in v0.27.0
func (m *MesosScheduler) SendFrameworkMessage(eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, s string) (mesosproto.Status, error)
func (*MesosScheduler) SlaveLost ¶ added in v0.27.0
func (m *MesosScheduler) SlaveLost(s scheduler.SchedulerDriver, sID *mesosproto.SlaveID)
func (*MesosScheduler) Start ¶ added in v0.27.0
func (m *MesosScheduler) Start() (mesosproto.Status, error)
func (*MesosScheduler) StatusUpdate ¶ added in v0.27.0
func (m *MesosScheduler) StatusUpdate(s scheduler.SchedulerDriver, ts *mesosproto.TaskStatus)
func (*MesosScheduler) Stop ¶ added in v0.27.0
func (m *MesosScheduler) Stop(b bool) (mesosproto.Status, error)
type Scheduler ¶
type Scheduler struct { ScheduleTaskFn func(req eremetic.Request) (string, error) ScheduleTaskInvoked bool KillFn func(id string) error KillInvoked bool }
Scheduler mocks the eremetic scheduler.
type TaskDB ¶
type TaskDB struct { CleanFn func() error CloseFn func() PutTaskFn func(*eremetic.Task) error ReadTaskFn func(string) (eremetic.Task, error) ReadUnmaskedTaskFn func(string) (eremetic.Task, error) DeleteTaskFn func(string) error ListNonTerminalTasksFn func() ([]*eremetic.Task, error) }
TaskDB mocks the eremetic task database.
func (*TaskDB) DeleteTask ¶ added in v0.27.0
ReadUnmaskedTask invokes the ReadUnmaskedTaskFn function.
func (*TaskDB) ListNonTerminalTasks ¶
ListNonTerminalTasks invokes the ListNonTerminalTasksFn function.
Click to show internal directories.
Click to hide internal directories.