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 *operator.OperatorConfig) error
  • func (s OperatorOptions) ExporterImage() string
  • func (s OperatorOptions) HAProxyImage() string
  • func (s *OperatorOptions) Validate() []error
  • func (s OperatorOptions) WatchNamespace() string
• type VoyagerOptions
  • func NewVoyagerOptions(out, errOut io.Writer) *VoyagerOptions
  • func (o *VoyagerOptions) AddFlags(fs *pflag.FlagSet)
  • func (o *VoyagerOptions) Complete() error
  • func (o VoyagerOptions) Config() (*server.VoyagerConfig, error)
  • func (o VoyagerOptions) Run(stopCh <-chan struct{}) error
  • func (o VoyagerOptions) Validate(args []string) error

Types

type OperatorOptions

type OperatorOptions struct {
	CloudProvider               string
	CloudConfigFile             string
	IngressClass                string
	OperatorNamespace           string
	OperatorService             string
	RestrictToOperatorNamespace bool
	QPS                         float64
	Burst                       int
	ResyncPeriod                time.Duration
	MaxNumRequeues              int
	NumThreads                  int
	DockerRegistry              string
	HAProxyImageTag             string
	HAProxyImageRepository      string
	ExporterImageTag            string
	ExporterImageRepository     string

	ValidateHAProxyConfig bool

	EnableValidatingWebhook bool
	// contains filtered or unexported fields
}

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 *operator.OperatorConfig) error

func (OperatorOptions) ExporterImage

func (s OperatorOptions) ExporterImage() string

func (OperatorOptions) HAProxyImage

func (s OperatorOptions) HAProxyImage() string

func (*OperatorOptions) Validate

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

func (OperatorOptions) WatchNamespace

func (s OperatorOptions) WatchNamespace() string

type VoyagerOptions

type VoyagerOptions struct {
	RecommendedOptions *genericoptions.RecommendedOptions
	OperatorOptions    *OperatorOptions

	StdOut io.Writer
	StdErr io.Writer
}

func NewVoyagerOptions

func NewVoyagerOptions(out, errOut io.Writer) *VoyagerOptions

func (*VoyagerOptions) AddFlags

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

func (*VoyagerOptions) Complete

func (o *VoyagerOptions) Complete() error

func (VoyagerOptions) Config

func (o VoyagerOptions) Config() (*server.VoyagerConfig, error)

func (VoyagerOptions) Run

func (o VoyagerOptions) Run(stopCh <-chan struct{}) error

func (VoyagerOptions) Validate

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