server

Documentation

Index

• type ExtraOptions
  • func NewExtraOptions() *ExtraOptions
  • func (s *ExtraOptions) AddFlags(fs *pflag.FlagSet)
  • func (s *ExtraOptions) AddGoFlags(fs *flag.FlagSet)
  • func (s *ExtraOptions) ApplyTo(cfg *controllers.Config) error
  • func (c *ExtraOptions) Validate() []error
• type SupervisorOperatorOptions
  • func NewSupervisorOperatorOptions(out, errOut io.Writer) *SupervisorOperatorOptions
  • func (o SupervisorOperatorOptions) AddFlags(fs *pflag.FlagSet)
  • func (o *SupervisorOperatorOptions) Complete() error
  • func (o SupervisorOperatorOptions) Config() (*server.SupervisorOperatorConfig, error)
  • func (o SupervisorOperatorOptions) Run(ctx context.Context) error
  • func (o SupervisorOperatorOptions) Validate(args []string) error

Types

type ExtraOptions

type ExtraOptions struct {
	QPS   float64
	Burst int

	ResyncPeriod           time.Duration
	MaxConcurrentReconcile int // NumThreads
	RequeueAfterDuration   time.Duration
	MaxRetryOnFailure      int // MaxNumRequeues
	RetryAfterDuration     time.Duration
	BeforeDeadlineDuration time.Duration

	EnableValidatingWebhook bool
	EnableMutatingWebhook   bool
}

func NewExtraOptions

func NewExtraOptions() *ExtraOptions

func (*ExtraOptions) AddFlags

func (s *ExtraOptions) AddFlags(fs *pflag.FlagSet)

func (*ExtraOptions) AddGoFlags

func (s *ExtraOptions) AddGoFlags(fs *flag.FlagSet)

func (*ExtraOptions) ApplyTo

func (s *ExtraOptions) ApplyTo(cfg *controllers.Config) error

func (*ExtraOptions) Validate

func (c *ExtraOptions) Validate() []error

type SupervisorOperatorOptions

type SupervisorOperatorOptions struct {
	RecommendedOptions *genericoptions.RecommendedOptions
	ExtraOptions       *ExtraOptions

	StdOut io.Writer
	StdErr io.Writer
}

func NewSupervisorOperatorOptions

func NewSupervisorOperatorOptions(out, errOut io.Writer) *SupervisorOperatorOptions

func (SupervisorOperatorOptions) AddFlags

func (o SupervisorOperatorOptions) AddFlags(fs *pflag.FlagSet)

func (*SupervisorOperatorOptions) Complete

func (o *SupervisorOperatorOptions) Complete() error

func (SupervisorOperatorOptions) Config

func (o SupervisorOperatorOptions) Config() (*server.SupervisorOperatorConfig, error)

func (SupervisorOperatorOptions) Run

func (o SupervisorOperatorOptions) Run(ctx context.Context) error

func (SupervisorOperatorOptions) Validate

func (o SupervisorOperatorOptions) Validate(args []string) error