scheduler

package

Go to main page

Versions in this module

v1

v1.2.0

Jun 23, 2016

v0

v0.4.0

Jun 23, 2016

Changes in this version

+ var ErrDisconnected = errors.New("disconnected from mesos master")

type MesosSchedulerDriver

+ func (driver *MesosSchedulerDriver) AcceptOffers(offerIds []*mesos.OfferID, operations []*mesos.Offer_Operation, ...) (mesos.Status, error)

type SchedulerDriver

+ AcceptOffers func(offerIDs []*mesos.OfferID, operations []*mesos.Offer_Operation, ...) (mesos.Status, error)

+ type TestDriver struct

+ func (t *TestDriver) CacheOffer(offer *mesos.Offer, pid *upid.UPID)

+ func (t *TestDriver) Context() context.Context

+ func (t *TestDriver) Done() <-chan struct{}

+ func (t *TestDriver) Fatal(ctx context.Context, msg string)

+ func (t *TestDriver) Framework() *mesos.FrameworkInfo

+ func (t *TestDriver) FrameworkRegistered(ctx context.Context, from *upid.UPID, msg proto.Message)

+ func (t *TestDriver) FrameworkReregistered(ctx context.Context, from *upid.UPID, msg proto.Message)

+ func (t *TestDriver) HandleMasterChanged(ctx context.Context, from *upid.UPID, msg proto.Message)

+ func (t *TestDriver) MasterPID() *upid.UPID

+ func (t *TestDriver) OnDispatch(f func(ctx context.Context, upid *upid.UPID, msg proto.Message) error)

+ func (t *TestDriver) SetConnected(b bool)

+ func (t *TestDriver) Started() <-chan struct{}

+ func (t *TestDriver) Stopped() <-chan struct{}

+ func (t *TestDriver) UPID() *upid.UPID

v0.3.0

Mar 16, 2016

v0.1.0

Oct 25, 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

+ NewDetector func() (detector.Master, error)

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

+ PublishedAddress net.IP

+ Scheduler Scheduler

+ WithAuthContext func(context.Context) context.Context

+ type ErrDriverAborted struct

+ Reason string

+ func (err *ErrDriverAborted) Error() string

+ 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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL