Versions in this module Expand all Collapse all v0 v0.4.0 Jun 23, 2016 Changes in this version type MockSchedulerDriver + func (m *MockSchedulerDriver) AcceptOffers(ids []*mesos.OfferID, ops []*mesos.Offer_Operation, f *mesos.Filters) (mesos.Status, error) v0.3.0 Mar 16, 2016 Changes in this version + type Config struct + Client *client.Client + ExecutorId *mesos.ExecutorID + FailoverTimeout float64 + LookupNode node.LookupFunc + ReconcileCooldown time.Duration + ReconcileInterval int64 + SchedulerConfig schedcfg.Config + StoreFrameworkId func(id string) + type Framework interface + Init func(sched scheduler.Scheduler, electedMaster proc.Process, mux *http.ServeMux) error + KillTask func(id string) error + LaunchTask func(t *podtask.T) error + Offers func() offers.Registry + Registration func() <-chan struct{} + func New(config Config) Framework + type JoinableDriver struct + func (m *JoinableDriver) Join() (mesos.Status, error) + func (m *JoinableDriver) Upon() <-chan struct{} + type MockSchedulerDriver struct + func (m *MockSchedulerDriver) Abort() (mesos.Status, error) + func (m *MockSchedulerDriver) DeclineOffer(oid *mesos.OfferID, f *mesos.Filters) (mesos.Status, error) + func (m *MockSchedulerDriver) Destroy() + func (m *MockSchedulerDriver) Init() error + func (m *MockSchedulerDriver) Join() (mesos.Status, error) + func (m *MockSchedulerDriver) KillTask(tid *mesos.TaskID) (mesos.Status, error) + func (m *MockSchedulerDriver) LaunchTasks(offerIds []*mesos.OfferID, ti []*mesos.TaskInfo, f *mesos.Filters) (mesos.Status, error) + func (m *MockSchedulerDriver) ReconcileTasks(statuses []*mesos.TaskStatus) (mesos.Status, error) + func (m *MockSchedulerDriver) RequestResources(r []*mesos.Request) (mesos.Status, error) + func (m *MockSchedulerDriver) ReviveOffers() (mesos.Status, error) + func (m *MockSchedulerDriver) Run() (mesos.Status, error) + func (m *MockSchedulerDriver) SendFrameworkMessage(eid *mesos.ExecutorID, sid *mesos.SlaveID, s string) (mesos.Status, error) + func (m *MockSchedulerDriver) Start() (mesos.Status, error) + func (m *MockSchedulerDriver) Stop(b bool) (mesos.Status, error) + func (m *MockSchedulerDriver) Upon() <-chan struct{} + func (m *MockSchedulerDriver) Wait()
Go to main page