Versions in this module Expand all Collapse all v0 v0.0.2 Sep 30, 2015 Changes in this version type DriverConfig + NewDetector func() (detector.Master, error) + type ErrDriverAborted struct + Reason string + func (err *ErrDriverAborted) Error() string v0.0.1 Sep 15, 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) + PublishedAddress net.IP + Scheduler Scheduler + WithAuthContext func(context.Context) context.Context + type MesosSchedulerDriver struct + 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) Running() bool + 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) + 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)
Go to main page