scheduler

type RunFunc func(ctx context.Context, agentID, input, sessionID string) error

type RunRecord struct {
	ID         string    `json:"id"`
	ScheduleID string    `json:"schedule_id"`
	AgentID    string    `json:"agent_id"`
	SessionID  string    `json:"session_id"`
	Input      string    `json:"input"`
	Status     string    `json:"status"` // success, error
	Error      string    `json:"error,omitempty"`
	StartedAt  time.Time `json:"started_at"`
	FinishedAt time.Time `json:"finished_at"`
}

type Schedule struct {
	ID         string    `json:"id"`
	AgentID    string    `json:"agent_id"`
	CronExpr   string    `json:"cron_expr"`
	Input      string    `json:"input"`
	NewSession bool      `json:"new_session"` // true = new session per run, false = reuse
	SessionID  string    `json:"session_id,omitempty"`
	Enabled    bool      `json:"enabled"`
	CreatedAt  time.Time `json:"created_at"`
	LastRunAt  time.Time `json:"last_run_at,omitempty"`
	NextRunAt  time.Time `json:"next_run_at,omitempty"`
	RunCount   int64     `json:"run_count"`
}

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