jobs

type BaseJob struct {
	JKey  string
	JType string
}

type CronJob struct {
	BaseJob
	Data     interface{}
	CronSpec string
	// contains filtered or unexported fields
}

type Job interface {
	Key() string
	Type() string

	// Should return Time.IsZero() when job is done.
	NextTriggerTime() time.Time
	// Used to count executions and post-processing.
	PostExecution(time.Time, error)

	Marshaler
	Unmarshaler
}

type Marshaler interface {
	Marshal() ([]byte, error)
}

type OneTimeJob struct {
	BaseJob
	Data        interface{}
	TriggerTime time.Time
	Executed    bool
}

type State uint32

type Unmarshaler interface {
	Unmarshal([]byte) error
}