Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mock

package

Go to main page

Versions in this module

v0

v0.28.0

Jun 23, 2017

v0.27.0

Apr 19, 2017

Changes in this version

type ErrScheduler

+ func (s *ErrScheduler) Kill(_id string) error

+ 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

+ DisconnectedFn func(scheduler.SchedulerDriver)

+ DisconnectedFnInvoked bool

+ ErrorFn func(scheduler.SchedulerDriver, string)

+ ErrorFnInvoked bool

+ ExecutorLostFn func(scheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, int)

+ ExecutorLostFnInvoked bool

+ FrameworkMessageFn func(scheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, string)

+ FrameworkMessageFnInvoked bool

+ JoinFn func() (mesosproto.Status, error)

+ JoinFnInvoked bool

+ KillTaskFn func(*mesosproto.TaskID) (mesosproto.Status, error)

+ KillTaskFnInvoked bool

+ LaunchTasksFn func([]*mesosproto.OfferID, []*mesosproto.TaskInfo, *mesosproto.Filters) (mesosproto.Status, error)

+ LaunchTasksFnInvoked bool

+ OfferRescindedFn func(scheduler.SchedulerDriver, *mesosproto.OfferID)

+ OfferRescindedFnInvoked bool

+ ReconcileTasksFn func([]*mesosproto.TaskStatus) (mesosproto.Status, error)

+ ReconcileTasksFnInvoked bool

+ RegisteredFn func(scheduler.SchedulerDriver, *mesosproto.FrameworkID, *mesosproto.MasterInfo)

+ RegisteredFnInvoked bool

+ RequestResourcesFn func([]*mesosproto.Request) (mesosproto.Status, error)

+ RequestResourcesFnInvoked bool

+ ReregisteredFn func(scheduler.SchedulerDriver, *mesosproto.MasterInfo)

+ ReregisteredFnInvoked bool

+ ResourceOffersFn func(scheduler.SchedulerDriver, []*mesosproto.Offer)

+ ResourceOffersFnInvoked bool

+ ReviveOffersFn func() (mesosproto.Status, error)

+ ReviveOffersFnInvoked bool

+ RunFn func() (mesosproto.Status, error)

+ RunFnInvoked bool

+ SendFrameworkMessageFn func(*mesosproto.ExecutorID, *mesosproto.SlaveID, string) (mesosproto.Status, error)

+ SendFrameworkMessageFnInvoked bool

+ SlaveLostFn func(scheduler.SchedulerDriver, *mesosproto.SlaveID)

+ SlaveLostFnInvoked bool

+ StartFn func() (mesosproto.Status, error)

+ StartFnInvoked bool

+ StatusUpdateFn func(scheduler.SchedulerDriver, *mesosproto.TaskStatus)

+ StatusUpdateFnInvoked bool

+ StopFn func(bool) (mesosproto.Status, error)

+ StopFnInvoked bool

+ func NewMesosScheduler() *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

+ KillFn func(id string) error

+ KillInvoked bool

+ func (s *Scheduler) Kill(id string) error

type TaskDB

+ DeleteTaskFn func(string) error

+ func (db *TaskDB) DeleteTask(id string) error

v0.26.0

Oct 4, 2016

v0.25.0

Sep 28, 2016

Changes in this version

+ type ErrScheduler struct

+ NextError *error

+ func (s *ErrScheduler) ScheduleTask(request eremetic.Request) (string, error)

+ type ErrorReader struct

+ func (r *ErrorReader) Read(p []byte) (int, error)

+ type Scheduler struct

+ ScheduleTaskFn func(req eremetic.Request) (string, error)

+ ScheduleTaskInvoked bool

+ func (s *Scheduler) ScheduleTask(req eremetic.Request) (string, error)

+ type TaskDB struct

+ CleanFn func() error

+ CloseFn func()

+ ListNonTerminalTasksFn func() ([]*eremetic.Task, error)

+ PutTaskFn func(*eremetic.Task) error

+ ReadTaskFn func(string) (eremetic.Task, error)

+ ReadUnmaskedTaskFn func(string) (eremetic.Task, error)

+ func (db *TaskDB) Clean() error

+ func (db *TaskDB) Close()

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