sched

type Context interface {
	Task() *Task
	Cancel() error
}

type Dispatcher interface {
	Register(typ string, handler interface{}) error
}

type Job struct {
	Id   string
	Typ  string
	Data interface{} `json:"-"`
	Raw  []byte
}

type Logger interface {
	Debugf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Warnf(format string, args ...interface{})
	Errorf(format string, args ...interface{})
}

type Manager interface {
	Dispatcher
	Scheduler
	Start() error
	Stop() error
}

type Option func(s *sched)

type Scheduler interface {
	Once(date time.Time, job *Job) error
	Every(period time.Duration, job *Job) error
	Cancel(job *Job) error
}

type Storage interface {
	Query() ([]*StoreItem, error)
	Upsert(item *StoreItem) error
	Delete(item *StoreItem) error
}

type StoreItem struct {
	Id   string
	Data []byte
}

type Task struct {
	*Job
	Next   time.Time
	Period time.Duration
	// contains filtered or unexported fields
}