task

type Job struct {
	JobID     string
	GroupID   string
	BeginTime string
	EndTime   string
	Timeout   time.Duration
	Seq       int
	Status    JobStatus

	FnIn  lang.AnyType
	FnOut lang.AnyType
	// contains filtered or unexported fields
}

type JobFunc func(jobID string, in lang.AnyType, out *lang.AnyType) error

type JobGroup struct {
	GroupID string

	CreateTime string
	Jobs       []*Job
	JobCount   int
	Sync       bool
	// contains filtered or unexported fields
}

type JobStatus int8

type KeyGenerator interface {
	Generate() []byte
}

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

type Store interface {
	Add(grpID string, jobID string, data lang.AnyType) error
	Get(jobID string) (lang.AnyType, bool)
	GetAll(grpID string) []lang.AnyType
	GetStatus(jobID string) int
	Update(jobID string, data lang.AnyType) error
	UpdateStatus(jobID string, status int) error
	Delete(jobID string) error
	Clear() error
}