runner

Documentation

Index

• Variables
• type Process
• type Runner
  • func New(closer closer.Closer, logger logger.Logger) Runner

Variables

var Component = &app.Component{
	Dependencies: app.Components{
		logger.Component,
	},
	Constructor: func(container container.Container) error {
		return container.Provide(New)
	},
	Serve: func(c container.Container) error {
		runner, err := container.Get[Runner](c)
		if err != nil {
			return err
		}

		return runner.Serve()
	},
}

var (
	ShutdownError = errors.New("runner: shutdown")
)

Types

type Process

type Process interface {
	Process(ctx context.Context) error
	Name() string
}

type Runner

type Runner interface {
	Serve() error
	AddProcesses(processes ...Process) error
}

func New

func New(closer closer.Closer, logger logger.Logger) Runner