Documentation
¶
Index ¶
- type ProcessStarter
- type ScheduleEntry
- type Scheduler
- func (s *Scheduler) AddProcess(name string, config *types.ScheduleConfig) error
- func (s *Scheduler) GetNextRunTime(name string) *time.Time
- func (s *Scheduler) GetScheduledProcesses() []string
- func (s *Scheduler) IsScheduled(name string) bool
- func (s *Scheduler) PauseProcess(name string) error
- func (s *Scheduler) ResumeProcess(name string) error
- func (s *Scheduler) Start()
- func (s *Scheduler) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProcessStarter ¶
type ProcessStarter interface {
StartProcess(name string) error
GetProcessState(name string) (*types.ProcessState, error)
}
ProcessStarter is an interface for starting processes.
type ScheduleEntry ¶
type ScheduleEntry struct {
ProcessName string
Config *types.ScheduleConfig
Job gocron.Job
RunningCount int
// contains filtered or unexported fields
}
ScheduleEntry tracks a scheduled process.
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler manages scheduled process execution.
func (*Scheduler) AddProcess ¶
func (s *Scheduler) AddProcess(name string, config *types.ScheduleConfig) error
AddProcess adds a scheduled process.
func (*Scheduler) GetNextRunTime ¶
GetNextRunTime returns the next scheduled run time for a process.
func (*Scheduler) GetScheduledProcesses ¶
GetScheduledProcesses returns a list of scheduled process names.
func (*Scheduler) IsScheduled ¶
IsScheduled returns true if the process has a schedule.
func (*Scheduler) PauseProcess ¶
PauseProcess pauses a scheduled job.
func (*Scheduler) ResumeProcess ¶
ResumeProcess resumes a paused scheduled job.
Source Files
Click to show internal directories.
Click to hide internal directories.