mock

package
v0.27.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2017 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ErrScheduler 

type ErrScheduler struct {
	NextError *error
}

ErrScheduler mocks the eremetic scheduler.

func (*ErrScheduler) Kill added in v0.27.0 

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

func (*ErrScheduler) ScheduleTask 

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

ScheduleTask records any scheduling errors.

type ErrorReader 

type ErrorReader struct{}

ErrorReader simulates a failure to read stream.

func (*ErrorReader) Read 

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

Read always returns an error.

type MesosScheduler added in v0.27.0 

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
	JoinFn                        func() (mesosproto.Status, error)
	JoinFnInvoked                 bool
	KillTaskFn                    func(*mesosproto.TaskID) (mesosproto.Status, error)
	KillTaskFnInvoked             bool
	ReconcileTasksFn              func([]*mesosproto.TaskStatus) (mesosproto.Status, error)
	ReconcileTasksFnInvoked       bool
	RequestResourcesFn            func([]*mesosproto.Request) (mesosproto.Status, error)
	RequestResourcesFnInvoked     bool
	ReviveOffersFn                func() (mesosproto.Status, error)
	ReviveOffersFnInvoked         bool
	RunFn                         func() (mesosproto.Status, error)
	RunFnInvoked                  bool
	StartFn                       func() (mesosproto.Status, error)
	StartFnInvoked                bool
	StopFn                        func(bool) (mesosproto.Status, error)
	StopFnInvoked                 bool
	SendFrameworkMessageFn        func(*mesosproto.ExecutorID, *mesosproto.SlaveID, string) (mesosproto.Status, error)
	SendFrameworkMessageFnInvoked bool
	LaunchTasksFn                 func([]*mesosproto.OfferID, []*mesosproto.TaskInfo, *mesosproto.Filters) (mesosproto.Status, error)
	LaunchTasksFnInvoked          bool
	RegisteredFn                  func(scheduler.SchedulerDriver, *mesosproto.FrameworkID, *mesosproto.MasterInfo)
	RegisteredFnInvoked           bool
	ReregisteredFn                func(scheduler.SchedulerDriver, *mesosproto.MasterInfo)
	ReregisteredFnInvoked         bool
	DisconnectedFn                func(scheduler.SchedulerDriver)
	DisconnectedFnInvoked         bool
	ResourceOffersFn              func(scheduler.SchedulerDriver, []*mesosproto.Offer)
	ResourceOffersFnInvoked       bool
	OfferRescindedFn              func(scheduler.SchedulerDriver, *mesosproto.OfferID)
	OfferRescindedFnInvoked       bool
	StatusUpdateFn                func(scheduler.SchedulerDriver, *mesosproto.TaskStatus)
	StatusUpdateFnInvoked         bool
	FrameworkMessageFn            func(scheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, string)
	FrameworkMessageFnInvoked     bool
	SlaveLostFn                   func(scheduler.SchedulerDriver, *mesosproto.SlaveID)
	SlaveLostFnInvoked            bool
	ExecutorLostFn                func(scheduler.SchedulerDriver, *mesosproto.ExecutorID, *mesosproto.SlaveID, int)
	ExecutorLostFnInvoked         bool
	ErrorFn                       func(scheduler.SchedulerDriver, string)
	ErrorFnInvoked                bool
}

MesosScheduler implements a mocked mesos scheduler iterface for testing

func NewMesosScheduler added in v0.27.0 

func NewMesosScheduler() *MesosScheduler

NewMesosScheduler returns a new mocked mesos scheduler

func (*MesosScheduler) Abort added in v0.27.0 

func (m *MesosScheduler) Abort() (stat mesosproto.Status, err error)

func (*MesosScheduler) AcceptOffers added in v0.27.0 

func (m *MesosScheduler) AcceptOffers(offerIds []*mesosproto.OfferID, operations []*mesosproto.Offer_Operation, filters *mesosproto.Filters) (mesosproto.Status, error)

func (*MesosScheduler) DeclineOffer added in v0.27.0 

func (m *MesosScheduler) DeclineOffer(offerID *mesosproto.OfferID, filters *mesosproto.Filters) (mesosproto.Status, error)

func (*MesosScheduler) Disconnected added in v0.27.0 

func (m *MesosScheduler) Disconnected(s scheduler.SchedulerDriver)

func (*MesosScheduler) Error added in v0.27.0 

func (m *MesosScheduler) Error(d scheduler.SchedulerDriver, msg string)

func (*MesosScheduler) ExecutorLost added in v0.27.0 

func (m *MesosScheduler) ExecutorLost(sd scheduler.SchedulerDriver, eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, i int)

func (*MesosScheduler) FrameworkMessage added in v0.27.0 

func (m *MesosScheduler) FrameworkMessage(sd scheduler.SchedulerDriver, eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, s string)

func (*MesosScheduler) Join added in v0.27.0 

func (m *MesosScheduler) Join() (mesosproto.Status, error)

func (*MesosScheduler) KillTask added in v0.27.0 

func (m *MesosScheduler) KillTask(id *mesosproto.TaskID) (mesosproto.Status, error)

func (*MesosScheduler) LaunchTasks added in v0.27.0 

func (m *MesosScheduler) LaunchTasks(o []*mesosproto.OfferID, t []*mesosproto.TaskInfo, f *mesosproto.Filters) (mesosproto.Status, error)

func (*MesosScheduler) OfferRescinded added in v0.27.0 

func (m *MesosScheduler) OfferRescinded(s scheduler.SchedulerDriver, o *mesosproto.OfferID)

func (*MesosScheduler) ReconcileTasks added in v0.27.0 

func (m *MesosScheduler) ReconcileTasks(ts []*mesosproto.TaskStatus) (mesosproto.Status, error)

func (*MesosScheduler) Registered added in v0.27.0 

func (m *MesosScheduler) Registered(s scheduler.SchedulerDriver, f *mesosproto.FrameworkID, minfo *mesosproto.MasterInfo)

func (*MesosScheduler) RequestResources added in v0.27.0 

func (m *MesosScheduler) RequestResources(r []*mesosproto.Request) (mesosproto.Status, error)

func (*MesosScheduler) Reregistered added in v0.27.0 

func (m *MesosScheduler) Reregistered(s scheduler.SchedulerDriver, info *mesosproto.MasterInfo)

func (*MesosScheduler) ResourceOffers added in v0.27.0 

func (m *MesosScheduler) ResourceOffers(s scheduler.SchedulerDriver, o []*mesosproto.Offer)

func (*MesosScheduler) ReviveOffers added in v0.27.0 

func (m *MesosScheduler) ReviveOffers() (mesosproto.Status, error)

func (*MesosScheduler) Run added in v0.27.0 

func (m *MesosScheduler) Run() (mesosproto.Status, error)

func (*MesosScheduler) SendFrameworkMessage added in v0.27.0 

func (m *MesosScheduler) SendFrameworkMessage(eID *mesosproto.ExecutorID, sID *mesosproto.SlaveID, s string) (mesosproto.Status, error)

func (*MesosScheduler) SlaveLost added in v0.27.0 

func (m *MesosScheduler) SlaveLost(s scheduler.SchedulerDriver, sID *mesosproto.SlaveID)

func (*MesosScheduler) Start added in v0.27.0 

func (m *MesosScheduler) Start() (mesosproto.Status, error)

func (*MesosScheduler) StatusUpdate added in v0.27.0 

func (m *MesosScheduler) StatusUpdate(s scheduler.SchedulerDriver, ts *mesosproto.TaskStatus)

func (*MesosScheduler) Stop added in v0.27.0 

func (m *MesosScheduler) Stop(b bool) (mesosproto.Status, error)

type Scheduler 

type Scheduler struct {
	ScheduleTaskFn      func(req eremetic.Request) (string, error)
	ScheduleTaskInvoked bool
	KillFn              func(id string) error
	KillInvoked         bool
}

Scheduler mocks the eremetic scheduler.

func (*Scheduler) Kill added in v0.27.0 

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

func (*Scheduler) ScheduleTask 

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

ScheduleTask invokes the ScheduleTaskFn function.

type TaskDB 

type TaskDB struct {
	CleanFn                func() error
	CloseFn                func()
	PutTaskFn              func(*eremetic.Task) error
	ReadTaskFn             func(string) (eremetic.Task, error)
	ReadUnmaskedTaskFn     func(string) (eremetic.Task, error)
	DeleteTaskFn           func(string) error
	ListNonTerminalTasksFn func() ([]*eremetic.Task, error)
}

TaskDB mocks the eremetic task database.

func (*TaskDB) Clean 

func (db *TaskDB) Clean() error

Clean invokes the CleanFn function.

func (*TaskDB) Close 

func (db *TaskDB) Close()

Close invokes the CloseFn function.

func (*TaskDB) DeleteTask added in v0.27.0 

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

ReadUnmaskedTask invokes the ReadUnmaskedTaskFn function.

func (*TaskDB) ListNonTerminalTasks 

func (db *TaskDB) ListNonTerminalTasks() ([]*eremetic.Task, error)

ListNonTerminalTasks invokes the ListNonTerminalTasksFn function.

func (*TaskDB) PutTask 

func (db *TaskDB) PutTask(task *eremetic.Task) error

PutTask invokes the PutTaskFn function.

func (*TaskDB) ReadTask 

func (db *TaskDB) ReadTask(id string) (eremetic.Task, error)

ReadTask invokes the ReadTaskFn function.

func (*TaskDB) ReadUnmaskedTask 

func (db *TaskDB) ReadUnmaskedTask(id string) (eremetic.Task, error)

ReadUnmaskedTask invokes the ReadUnmaskedTaskFn function.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.