Documentation
¶
Index ¶
Constants ¶
View Source
const ( DelayFieldName = "runner.middleware.restore.delay" DelayDefault = 100 * time.Millisecond )
Variables ¶
View Source
var ( ComponentNoRegistration = &component.Component{ Name: "runner.middleware.restore.no_registration", Dependencies: component.Components{ runner.Component, }, Init: component.StepFunc(func(container container.Container) error { return container.Provides(NewConfig, NewRestore) }), BindFlags: component.BindFlags(func(flagSet flag.FlagSet, container container.Container) error { return container.Invoke(func(config *Config) { flagSet.DurationVar(&config.Delay, DelayFieldName, DelayDefault, "") }) }), Configuration: component.StepFunc(func(container container.Container) error { return container.Invoke(Configuration) }), } Component = &component.Component{ Name: "runner.middleware.restore", Dependencies: component.Components{ runner.Component, }, Init: component.StepFunc(func(container container.Container) error { return container.Provides(NewConfig, NewRestore) }), BindFlags: component.BindFlags(func(flagSet flag.FlagSet, container container.Container) error { return container.Invoke(func(config *Config) { flagSet.DurationVar(&config.Delay, DelayFieldName, DelayDefault, "") }) }), Configuration: component.StepFunc(func(container container.Container) error { if err := container.Invoke(Configuration); err != nil { return err } return container.Invoke(func(r runner.Runner, middleware *Restore) { r.Use(middleware) }) }), } )
Functions ¶
This section is empty.
Types ¶
type Config ¶
func Configuration ¶
func Configuration(config *Config, configurator configurator.Configurator) *Config
type Restore ¶
type Restore struct {
// contains filtered or unexported fields
}
func NewRestore ¶
func (*Restore) Middleware ¶
func (restore *Restore) Middleware(process runner.Process, next runner.ProcessFunc) runner.ProcessFunc
Click to show internal directories.
Click to hide internal directories.