Documentation
¶
Overview ¶
Package scheduler provides scheduled task execution for Claude CLI.
Package scheduler provides scheduled task execution for Claude CLI.
Package scheduler provides scheduled task execution for Claude CLI.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClaudeTaskExecutor ¶
type ClaudeTaskExecutor struct {
// contains filtered or unexported fields
}
ClaudeTaskExecutor executes tasks using Claude CLI
func NewClaudeTaskExecutor ¶
func NewClaudeTaskExecutor(claudePath, workingDir string) *ClaudeTaskExecutor
NewClaudeTaskExecutor creates a new Claude task executor
func (*ClaudeTaskExecutor) Execute ¶
func (e *ClaudeTaskExecutor) Execute(ctx context.Context, task config.ScheduledTask) error
Execute runs the task using Claude CLI
type SchedulerManager ¶
type SchedulerManager struct {
// contains filtered or unexported fields
}
SchedulerManager manages all scheduled tasks
func NewSchedulerManager ¶
func NewSchedulerManager(tasks []config.ScheduledTask, executor TaskExecutor) *SchedulerManager
NewSchedulerManager creates a new scheduler manager
func (*SchedulerManager) Start ¶
func (sm *SchedulerManager) Start()
Start launches all task runners
func (*SchedulerManager) Stats ¶
func (sm *SchedulerManager) Stats() []TaskStats
Stats returns statistics for all tasks
func (*SchedulerManager) Stop ¶
func (sm *SchedulerManager) Stop()
Stop gracefully shuts down all task runners
type TaskExecutor ¶
type TaskExecutor interface {
Execute(ctx context.Context, task config.ScheduledTask) error
}
TaskExecutor executes scheduled tasks
type TaskRunner ¶
type TaskRunner struct {
// contains filtered or unexported fields
}
TaskRunner manages execution of a single scheduled task
func NewTaskRunner ¶
func NewTaskRunner(task config.ScheduledTask, executor TaskExecutor) *TaskRunner
NewTaskRunner creates a new task runner
func (*TaskRunner) Start ¶
func (tr *TaskRunner) Start(parentStopCh chan struct{})
Start begins the ticker loop in a goroutine
func (*TaskRunner) Stats ¶
func (tr *TaskRunner) Stats() TaskStats
Stats returns execution statistics