entry_reader

package

v1.0.0 Latest Latest Go to latest Published: May 31, 2024 License: GPL-3.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(params Params) *EntryReader

func (er *EntryReader) LoadDags(serverName string) error

func (er *EntryReader) LogErr(msg string, err error)

func (er *EntryReader) Read(now time.Time) ([]*scheduler.Entry, error)

type JobFactory interface {
	NewJob(dag *dag.DAG, next time.Time) scheduler.Job
}

type Params struct {
	DagsDir       string
	JobFactory    JobFactory
	Logger        logger.Logger
	EngineFactory engine.Factory
}