Documentation
¶
Index ¶
- Variables
- type Option
- func WithLabels(labels map[string]string) Option
- func WithLogger(logger logrus.FieldLogger) Option
- func WithResourceModifiersManager(resourceModifiersManager *resourcemodifier.Manager) Option
- func WithResources(resources map[string]float64) Option
- func WithSecurity(security *security.Security) Option
- func WithStandby(standby *api.StandbyInstanceParameters) Option
- func WithTartPrePull(tartPrePull *TartPrePull) Option
- func WithUpstream(upstream *upstream.Upstream) Option
- type StandbyConfig
- type TartPrePull
- type Task
- type Worker
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInitializationFailed = errors.New("worker initialization failed") ErrShutdown = errors.New("worker is shutting down") )
View Source
var ErrIsolationMissing = errors.New("isolation configuration is required for standby")
View Source
var ErrUnsupportedIsolation = errors.New("only Tart and Vetu instances are currently supported for standby")
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(*Worker)
func WithLabels ¶
func WithLogger ¶ added in v0.30.0
func WithLogger(logger logrus.FieldLogger) Option
func WithResourceModifiersManager ¶ added in v0.122.0
func WithResourceModifiersManager(resourceModifiersManager *resourcemodifier.Manager) Option
func WithResources ¶ added in v0.79.0
func WithSecurity ¶ added in v0.102.0
func WithStandby ¶ added in v0.113.0
func WithStandby(standby *api.StandbyInstanceParameters) Option
func WithTartPrePull ¶ added in v0.129.0
func WithTartPrePull(tartPrePull *TartPrePull) Option
func WithUpstream ¶ added in v0.87.0
type StandbyConfig ¶ added in v0.113.0
type StandbyConfig struct {
*api.StandbyInstanceParameters
}
func (*StandbyConfig) UnmarshalYAML ¶ added in v0.113.0
func (standby *StandbyConfig) UnmarshalYAML(value *yaml.Node) error
type TartPrePull ¶ added in v0.134.0
type TartPrePull struct {
Images []string `yaml:"images"`
CheckInterval time.Duration `yaml:"check-interval"`
Jitter time.Duration `yaml:"jitter"`
LastCheck time.Time
}
func (TartPrePull) NeedsPrePull ¶ added in v0.134.0
func (pull TartPrePull) NeedsPrePull() bool
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) UpdateStandby ¶ added in v0.134.0
func (worker *Worker) UpdateStandby(ctx context.Context, parameters *api.StandbyInstanceParameters)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.