schedule

package
v1.0.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type DefaultScheduler added in v1.0.0 

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

func (*DefaultScheduler) AddTask added in v1.0.0 

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

func (*DefaultScheduler) GetTask added in v1.0.0 

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

func (*DefaultScheduler) Start added in v1.0.0 

func (s *DefaultScheduler) Start()

func (*DefaultScheduler) Stop added in v1.0.0 

func (s *DefaultScheduler) Stop()

type IntervalSchedule added in v1.0.0 

type IntervalSchedule struct {
	InitialDelay time.Duration
	Interval     time.Duration
	// contains filtered or unexported fields
}

func (*IntervalSchedule) Next added in v1.0.0 

func (s *IntervalSchedule) Next(t time.Time) time.Time

type Scheduler added in v1.0.0 

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

func NewScheduler added in v1.0.0 

func NewScheduler() Scheduler

type Task added in v1.0.0 

type Task struct {
	Name         string
	InitialDelay time.Duration
	Interval     time.Duration
	Do           func()
	// contains filtered or unexported fields
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.