Versions in this module Expand all Collapse all v0 v0.1.2 Sep 9, 2022 v0.1.1 Aug 31, 2022 Changes in this version + type Config struct + CloseTimeout time.Duration + TickTime time.Duration + type PointJob interface + Close func() error + GetLastAccessed func() time.Time + type PointScheduler struct + func NewPointScheduler(config Config) *PointScheduler + func (p *PointScheduler) Enqueue(point PointJob) + func (p *PointScheduler) IsRunning() bool + func (p *PointScheduler) SetMaxConcurrentJobs(n int) + func (p *PointScheduler) StartAsync() + func (p *PointScheduler) StartBlocking() + type State int64 + const RUNNING + const STALE
Go to main page