taskengine

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

type Dispatcher interface {
	Size() int
	Close()
	Enqueue(tick *Tick) error
	Dequeue() <-chan *Tick
	Capacity() int
}

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

type EngineOption func(*Engine)

type Job = func(ctx *Context) error

type Logger interface {
	Info(msg string)
	Infof(format string, args ...any)

	Warn(msg string)
	Warnf(format string, args ...any)

	Error(msg string)
	Errorf(format string, args ...any)
}

type LoggerFactory func(module string) Logger

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

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

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

type Trigger interface {
	Next(lastRun time.Time) (time.Time, error)
	String() string
}

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

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