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
	State() State
	Context() context.Context
	Progress() float64
	Err() error
	Result() any
	Start(ctx context.Context) bool
	ExecutionTime() time.Duration
	Wait()
	Cancel() bool
	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"`
}