rt

type Cache interface {
	Set(key string, val []byte, ttl int) error
	Get(key string) ([]byte, error)
	Delete(key string) error
}

type ChangeEvent int

type Ctx struct {
	Cache Cache
	// contains filtered or unexported fields
}

type DoFunc func(Job) *Result

type Group struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Job struct {
	JobReference
	// contains filtered or unexported fields
}

type JobFunc func(interface{}) *Result

type JobReference struct {
	// contains filtered or unexported fields
}

type MemoryStorage struct {
	// contains filtered or unexported fields
}

type Option func(workerOpts) workerOpts

type Reactr struct {
	// contains filtered or unexported fields
}

type Result struct {
	// contains filtered or unexported fields
}

type ResultFunc func(interface{}, error)

type RunErr struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type Runnable interface {
	// Run is the entrypoint for jobs handled by a Runnable
	Run(Job, *Ctx) (interface{}, error)

	// OnChange is called when the worker using the Runnable instance is going to change.
	// OnChange will be called for things like startup and shutdown.
	OnChange(ChangeEvent) error
}

type Schedule interface {
	Check() *Job
	Done() bool
}

type Storage interface {
	Add(Job) error
	AddResult(string, interface{}, error) error
	Get(string) (Job, error)
	Remove(string) error
}