scheduler

type AgentExecutor interface {
	Execute(ctx context.Context, agentName string, prompt string) (*JobResult, error)
}

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

type JobResult struct {
	Response string
	Error    error
}

type ScheduleType string

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

type Task struct {
	ID            string                 `json:"id"`
	AgentName     string                 `json:"agent_name"`
	Prompt        string                 `json:"prompt"`
	ScheduleType  ScheduleType           `json:"schedule_type"`
	ScheduleValue string                 `json:"schedule_value"`
	Status        TaskStatus             `json:"status"`
	NextRun       time.Time              `json:"next_run"`
	LastRun       *time.Time             `json:"last_run,omitempty"`
	CreatedAt     time.Time              `json:"created_at"`
	UpdatedAt     time.Time              `json:"updated_at"`
	ContextMode   string                 `json:"context_mode"`
	Metadata      map[string]interface{} `json:"metadata,omitempty"`
}

type TaskRun struct {
	ID         string    `json:"id"`
	TaskID     string    `json:"task_id"`
	RunAt      time.Time `json:"run_at"`
	DurationMs int64     `json:"duration_ms"`
	Status     string    `json:"status"` // "success", "error", "timeout"
	Result     string    `json:"result,omitempty"`
	Error      string    `json:"error,omitempty"`
}

type TaskStatus string

type TaskStore interface {
	// Create adds a new task
	Create(task *Task) error

	// Get retrieves a task by ID
	Get(id string) (*Task, error)

	// GetAll retrieves all tasks
	GetAll() ([]*Task, error)

	// GetDue retrieves tasks that are due for execution
	GetDue() ([]*Task, error)

	// GetByAgent retrieves all tasks for a specific agent
	GetByAgent(agentName string) ([]*Task, error)

	// Update updates an existing task
	Update(task *Task) error

	// Delete removes a task
	Delete(id string) error

	// LogRun records a task execution
	LogRun(run *TaskRun) error

	// GetRuns retrieves execution history for a task
	GetRuns(taskID string, limit int) ([]*TaskRun, error)

	// Close releases resources
	Close() error
}