worker

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 *StandbyConfig) Option
  • func WithTartPrePull(tartPrePull []string) Option
  • func WithUpstream(upstream *upstream.Upstream) Option
• type StandbyConfig
  • func (standby *StandbyConfig) UnmarshalYAML(value *yaml.Node) error
• type Task
• type Worker
  • func New(opts ...Option) (*Worker, error)
  • func (worker *Worker) Pause(ctx context.Context, wait bool) error
  • func (worker *Worker) Resume(ctx context.Context) (err error)
  • func (worker *Worker) Run(ctx context.Context) error

Variables

var (
	ErrInitializationFailed = errors.New("worker initialization failed")
	ErrShutdown             = errors.New("worker is shutting down")
)

var ErrIsolationMissing = errors.New("isolation configuration is required for standby")

var ErrUnsupportedIsolation = errors.New("only Tart and Vetu instances are currently supported for standby")

Types

type Option

type Option func(*Worker)

func WithLabels

func WithLabels(labels map[string]string) Option

func WithLogger

func WithLogger(logger logrus.FieldLogger) Option

func WithResourceModifiersManager

func WithResourceModifiersManager(resourceModifiersManager *resourcemodifier.Manager) Option

func WithResources

func WithResources(resources map[string]float64) Option

func WithSecurity

func WithSecurity(security *security.Security) Option

func WithStandby

func WithStandby(standby *StandbyConfig) Option

func WithTartPrePull

func WithTartPrePull(tartPrePull []string) Option

func WithUpstream

func WithUpstream(upstream *upstream.Upstream) Option

type StandbyConfig

type StandbyConfig struct {
	Isolation *api.Isolation
	Resources map[string]float64
}

func (*StandbyConfig) UnmarshalYAML

func (standby *StandbyConfig) UnmarshalYAML(value *yaml.Node) error

type Task

type Task struct {
	// contains filtered or unexported fields
}

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (*Worker, error)

func (*Worker) Pause

func (worker *Worker) Pause(ctx context.Context, wait bool) error

func (*Worker) Resume

func (worker *Worker) Resume(ctx context.Context) (err error)

func (*Worker) Run

func (worker *Worker) Run(ctx context.Context) error