schedule

package

v1.0.1 Latest Latest Go to latest Published: Feb 6, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrTaskAdded = errors.New("task already added")
)

This section is empty.

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

func NewSchedulerService() *ScheduleService

func (s *ScheduleService) AddTask(task *Task)

func (s *ScheduleService) GetTask(id string) *Task

func (s *ScheduleService) Name() string

func (s *ScheduleService) Start() error

func (s *ScheduleService) Stop(_ context.Context) error

type Scheduler interface {
	AddTask(task *Task)
	GetTask(name string) *Task
}

type Task struct {
	Name         string
	InitialDelay time.Duration
	Interval     time.Duration
	Do           func()
}