mock

Documentation

Index

• type ErrScheduler
  • func (s *ErrScheduler) ScheduleTask(request eremetic.Request) (string, error)
• type ErrorReader
  • func (r *ErrorReader) Read(p []byte) (int, error)
• type Scheduler
  • func (s *Scheduler) ScheduleTask(req eremetic.Request) (string, error)
• type TaskDB
  • 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)

Types

type ErrScheduler

type ErrScheduler struct {
	NextError *error
}

func (*ErrScheduler) ScheduleTask

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

type ErrorReader

type ErrorReader struct{}

func (*ErrorReader) Read

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

type Scheduler

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

func (*Scheduler) ScheduleTask

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

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)
	ListNonTerminalTasksFn func() ([]*eremetic.Task, error)
}

func (*TaskDB) Clean

func (db *TaskDB) Clean() error

func (*TaskDB) Close

func (db *TaskDB) Close()

func (*TaskDB) ListNonTerminalTasks

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

func (*TaskDB) PutTask

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

func (*TaskDB) ReadTask

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

func (*TaskDB) ReadUnmaskedTask

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