jobfx

Nov 9, 2026

Changes in this version

+ var ErrAssignmentAlreadySet = errors.New("assignment is already configured")

+ var ErrAssignmentSourceIsNil = errors.New("assignment source is nil")

+ func Execute(inputs ...any)

type App

+ func (a *App) WithAssignment(source AssignmentSource) *App

+ type AssignmentSource func(context.Context) (assignment.Config, assignment.Invocation, error)

+ type ExecuteOption interface

+ func WithAssignment(source AssignmentSource) ExecuteOption

type Result

+ Assignment *assignment.Decision

Nov 9, 2026

Changes in this version

+ var ErrAppBusy = errors.New("application is busy")

+ var ErrAppUsed = errors.New("application has already been used")

+ var ErrApplicationIsNil = errors.New("application is nil")

+ var ErrContextIsNil = errors.New("context is nil")

+ var ErrInvalidTimeout = errors.New("timeout must not be negative")

+ type App struct

+ func MakeApp(options ...fx.Option) *App

+ func New(application Application) *App

+ func (a *App) Start(ctx context.Context) (Result, error)

+ func (a *App) Stop() error

+ func (a *App) WithConfig(cfg AppConfig) *App

+ type AppConfig struct

+ CleanupTimeout time.Duration

+ ObserveTimeout time.Duration

+ StartupTimeout time.Duration

+ type Application interface

+ FX func() fx.Option

+ HandleCLI func(args []string, output io.Writer) (isHandled bool, err error)

+ type Result struct

+ IsCLIHandled bool

+ Job *job.Result

+ func (r Result) ExitCode() int

Sep 20, 2026

Changes in this version

+ func Module(opts ...job.Option) fx.Option

+ type Options []job.Option