scheduler

package
v0.0.0-...-12e3ab2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 5, 2026 License: MIT Imports: 13 Imported by: 0

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

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

type TaskStats

type TaskStats struct {
	Name      string
	LastRun   *time.Time
	RunCount  int64
	LastError string
}

TaskStats contains execution statistics for a task

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
⌂ 换网址