scheduler

package

v3.0.0-rc15 Latest Latest Go to latest Published: May 22, 2026 License: Apache-2.0 Imports: 34 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Job struct {
	CreatedAt time.Time
	LastRunAt time.Time
	// contains filtered or unexported fields
}

Job is a schedule entries with alarms set.

func (t Job) Cancel()

type Jobs map[string]Job

Jobs is a map of Job

func (t Jobs) Add(e schedule.Entry, delay time.Duration, bus chan any)

func (t Jobs) Del(e schedule.Entry)

func (t Jobs) DelId(jobId string)

func (t Jobs) DelPath(p naming.Path)

func (t Jobs) Done(e schedule.Entry) Job

func (t Jobs) Get(e schedule.Entry) (Job, bool)

func (t Jobs) Has(e schedule.Entry) bool

func (t Jobs) PathIds(path naming.Path) []string

func (t Jobs) Purge()

func (t Jobs) Table(path naming.Path) schedule.Table

type Schedules map[naming.Path]map[string]schedule.Entry

func (t Schedules) Add(path naming.Path, e schedule.Entry)

func (t Schedules) Del(path naming.Path, key string)

func (t Schedules) DelPath(path naming.Path)

func (t Schedules) Get(path naming.Path, k string) (schedule.Entry, bool)

func (t Schedules) Table(path naming.Path) (l schedule.Table)

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

func New(subQS pubsub.QueueSizer, opts ...funcopt.O) *T

func (t *T) Start(ctx context.Context) error

func (t *T) Stop() error