job

type Context interface {
	ID() string
	Context() context.Context
	Logger() log.Logger
	Labels() labels.Set
	SetProgress(progress float64)
	SetResult(result any)
	GetParams() any
}

type Func func(ctx Context) error

type Job interface {
	ID() string
	Labels() labels.Set
	CreatedAt() time.Time
	StartedAt() time.Time
	EndedAt() time.Time
	Run(ctx context.Context, params any) bool
	Wait()
	Cancel() bool
	Result() any
	Err() error
	State() State
	Context() context.Context
	Progress() float64
	ExecutionTime() time.Duration
	IsExecuting() bool
	IsDone() bool
	IsState(state State) bool
	Stats() *Stats
}

type Option func(*job)

type State string

type Stats struct {
	ID            string        `json:"id"`
	State         string        `json:"state"`
	Progress      float64       `json:"progress"`
	StartedAt     time.Time     `json:"started_at"`
	ExecutionTime time.Duration `json:"execution_time"`
	Labels        labels.Set    `json:"labels"`
	Error         string        `json:"error"`
}