scheduler

Documentation

Index

• Variables
• func EntryReaderProvider(cfg *config.Config, engineFactory engine.Factory, jf entry_reader.JobFactory, ...) scheduler.EntryReader
• func JobFactoryProvider(cfg *config.Config, engineFactory engine.Factory) entry_reader.JobFactory
• func LifetimeHooks(lc fx.Lifecycle, a *scheduler.Scheduler)
• func New(params Params) *scheduler.Scheduler
• type Params

Variables

var Module = fx.Options(
	fx.Provide(EntryReaderProvider),
	fx.Provide(JobFactoryProvider),
	fx.Provide(New),
)

Functions

func EntryReaderProvider

func EntryReaderProvider(
	cfg *config.Config,
	engineFactory engine.Factory,
	jf entry_reader.JobFactory,
	logger logger.Logger,
) scheduler.EntryReader

func JobFactoryProvider

func JobFactoryProvider(cfg *config.Config, engineFactory engine.Factory) entry_reader.JobFactory

func LifetimeHooks

func LifetimeHooks(lc fx.Lifecycle, a *scheduler.Scheduler)

func New

func New(params Params) *scheduler.Scheduler

Types

type Params

type Params struct {
	fx.In

	Config      *config.Config
	Logger      logger.Logger
	EntryReader scheduler.EntryReader
}