scheduler

package

v3.0.0-beta13 Latest Latest Go to latest Published: Jan 20, 2026 License: Apache-2.0 Imports: 31 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
}

func (t Job) Cancel()

type Jobs map[string]Job

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

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

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) 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) DelByPath(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