worker

type BaseTask struct {
	ID           string        `json:"id"`
	Type         string        `json:"type"`
	Priority     int           `json:"priority"`
	Dependencies []string      `json:"dependencies"`
	Timeout      time.Duration `json:"timeout"`
	RetryPolicy  RetryPolicy   `json:"retry_policy"`

	// Execution state (previously in TaskResult)
	Status    TaskStatus             `json:"status"`
	StartTime time.Time              `json:"start_time"`
	EndTime   time.Time              `json:"end_time"`
	Error     error                  `json:"error"`
	Progress  float64                `json:"progress"`
	Metadata  map[string]interface{} `json:"metadata"`
	// contains filtered or unexported fields
}

type RetryPolicy struct {
	MaxAttempts       int
	InitialDelay      time.Duration
	MaxDelay          time.Duration
	BackoffMultiplier float64
}

type Task interface {
	// Core task properties
	GetID() string
	GetType() string
	GetPriority() int
	GetDependencies() []string

	// Execution methods
	Execute(ctx context.Context) error
	Validate() error

	// Configuration
	GetTimeout() time.Duration
	GetRetryPolicy() RetryPolicy

	// Execution state (previously in TaskResult)
	GetStatus() TaskStatus
	SetStatus(status TaskStatus)
	GetStartTime() time.Time
	SetStartTime(time time.Time)
	GetEndTime() time.Time
	SetEndTime(time time.Time)

	// Execution results (previously in TaskResult)
	GetError() error
	SetError(error error)
	GetProgress() float64
	SetProgress(progress float64)
	GetMetadata() map[string]interface{}
	SetMetadata(metadata map[string]interface{})

	// Convenience methods
	IsCompleted() bool
	IsFailed() bool
	IsRunning() bool
}

type TaskFilter struct {
	Type      string
	Status    TaskStatus
	StartTime time.Time
	EndTime   time.Time
}

type TaskStatus string