cronjob

package module

v0.0.3 Latest Latest Go to latest Published: Sep 20, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var ErrNoItem = errors.New("key not found")

View Source

var ErrUnknownFormat = errors.New("unknown format")

This section is empty.

type CronConfig struct {
	EndTime    time.Time
	Expression string
	// contains filtered or unexported fields
}

func (c CronConfig) Next(offset time.Time) time.Time

type CronItem[T any, K comparable] struct {
	// contains filtered or unexported fields
}

func (node *CronItem[T, K]) Compare(that *CronItem[T, K]) int

func (node *CronItem[T, K]) Value() *T

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

func NewCronParser(loc *time.Location) *CronParser

func (ts CronParser) LocalTime() time.Time

func (ts CronParser) LocalTimeString(t time.Time) string

func (ts CronParser) Parse(s string) (CronConfig, error)

type CronQueue[T any, K comparable] struct {
	// contains filtered or unexported fields
}

func (s *CronQueue[T, K]) DisplayAll()

func (s *CronQueue[T, K]) Find(key K) (value T, nextSched time.Time, err error)

func (s *CronQueue[T, K]) Insert(sortKey time.Time, key K, value T)

func (s *CronQueue[T, K]) IsEmpty() bool

func (s *CronQueue[T, K]) NextSchedule() time.Time

func (s *CronQueue[T, K]) Pop() (T, error)

func (s *CronQueue[T, K]) Remove(key K) error

type Manager[K comparable] struct {
	// contains filtered or unexported fields
}

func NewManager[K comparable](loc *time.Location) *Manager[K]

func (s *Manager[K]) AddTask(config CronConfig, id K, job func())

func (s *Manager[K]) FindTask(id K) (*Task[K], time.Time)

func (s *Manager[K]) RemoveTasks(ids ...K)

func (s *Manager[K]) Run(ctx context.Context)

type Task[K comparable] struct {
	Config CronConfig
	ID     K
	Run    func()
	// contains filtered or unexported fields
}