The highest tagged major version is v2.

scheduler

package

v1.0.10 Latest Latest Go to latest Published: Nov 21, 2021 License: MIT Imports: 15 Imported by: 0

Details

View Source

const (
	SCHEDULER_RUN  = "run"
	SCHEDULER_STOP = "stop"
)

This section is empty.

This section is empty.

type Option func(opts *Options)

func WithNode(node *node.Node) Option

type Options struct {
	Node *node.Node
}

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

func New(opts ...Option) (s *Scheduler)

func (s *Scheduler) Run(ctx context.Context) (err error)

func (s *Scheduler) Stop()

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