mock

Documentation

Index

• type MockScheduler
  • func New() *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)

Types

type MockScheduler

type MockScheduler struct {
	mock.Mock
}

func New

func New() *MockScheduler

func (*MockScheduler) Disconnected

func (sched *MockScheduler) Disconnected(SchedulerDriver)

func (*MockScheduler) Error

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

func (*MockScheduler) ExecutorLost

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

func (*MockScheduler) FrameworkMessage

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

func (*MockScheduler) OfferRescinded

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

func (*MockScheduler) Registered

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

func (*MockScheduler) Reregistered

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

func (*MockScheduler) ResourceOffers

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

func (*MockScheduler) SlaveLost

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

func (*MockScheduler) StatusUpdate

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