server

Documentation

Index

• type OperatorOptions
  • func NewOperatorOptions() *OperatorOptions
  • func (s *OperatorOptions) AddFlags(fs *pflag.FlagSet)
  • func (s *OperatorOptions) AddGoFlags(fs *flag.FlagSet)
  • func (s *OperatorOptions) ApplyTo(cfg *controller.OperatorConfig) error
  • func (s *OperatorOptions) Complete() error
  • func (s OperatorOptions) Config() (*controller.OperatorConfig, error)
  • func (s OperatorOptions) Run(ctx context.Context) error
  • func (s *OperatorOptions) Validate() []error

Types

type OperatorOptions

type OperatorOptions struct {
	QPS            float64
	Burst          int
	ResyncPeriod   time.Duration
	MaxNumRequeues int
	NumThreads     int
}

func NewOperatorOptions

func NewOperatorOptions() *OperatorOptions

func (*OperatorOptions) AddFlags

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

func (*OperatorOptions) AddGoFlags

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

func (*OperatorOptions) ApplyTo

func (s *OperatorOptions) ApplyTo(cfg *controller.OperatorConfig) error

func (*OperatorOptions) Complete

func (s *OperatorOptions) Complete() error

func (OperatorOptions) Config

func (s OperatorOptions) Config() (*controller.OperatorConfig, error)

func (OperatorOptions) Run

func (s OperatorOptions) Run(ctx context.Context) error

func (*OperatorOptions) Validate

func (s *OperatorOptions) Validate() []error