schedule_manager

package
v0.0.5 Latest Latest
Warning

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

Go to latest
Published: Oct 5, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var NewScheduleManager = func() *scheduleManager {
	sm := &scheduleManager{
		ScheduleCh: make(chan string, 1),
		cron:       cron.New(),
		Entries:    make(map[string]CronEntry),
	}
	return sm
}

Functions

This section is empty.

Types

type CronEntry

type CronEntry struct {
	EntryID cron.EntryID
	Ids     map[string]bool
}

type ScheduleManager

type ScheduleManager interface {
	WithContext(ctx context.Context)
	Stop()
	Start()
	Add(entry ScheduleEntry)
	Remove(entry ScheduleEntry)
	Ch() chan string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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