v3

Documentation

Index

• type Pilot
  • func NewPilot(opts *PilotOptions) (*Pilot, error)
  • func (p *Pilot) CmdFunc(pilot *v1alpha1.Pilot) (*exec.Cmd, error)
  • func (p *Pilot) Hooks() *hook.Hooks
  • func (p *Pilot) LivenessCheck() error
  • func (p *Pilot) ReadinessCheck() error
  • func (p *Pilot) WaitForCacheSync(stopCh <-chan struct{}) error
• type PilotOptions
  • func NewOptions(out, errOut io.Writer) *PilotOptions
  • func (o *PilotOptions) AddFlags(flags *pflag.FlagSet)
  • func (o *PilotOptions) Complete() error
  • func (o *PilotOptions) Run(stopCh <-chan struct{}) error
  • func (o *PilotOptions) Validate() error

Types

type Pilot

type Pilot struct {
	Options *PilotOptions
	// contains filtered or unexported fields
}

func NewPilot

func NewPilot(opts *PilotOptions) (*Pilot, error)

func (*Pilot) CmdFunc

func (p *Pilot) CmdFunc(pilot *v1alpha1.Pilot) (*exec.Cmd, error)

func (*Pilot) Hooks

func (p *Pilot) Hooks() *hook.Hooks

func (*Pilot) LivenessCheck

func (p *Pilot) LivenessCheck() error

func (*Pilot) ReadinessCheck

func (p *Pilot) ReadinessCheck() error

func (*Pilot) WaitForCacheSync

func (p *Pilot) WaitForCacheSync(stopCh <-chan struct{}) error

type PilotOptions

type PilotOptions struct {
	// RestConfig is the clientset configuration to connection to the apiserver
	// If not specified, autoconfiguration will be performed using the provided
	// master address and kubeconfig path. If these are not specified,
	// in-cluster configuration will be attempted to be loaded.
	RestConfig *rest.Config

	// Master is an optional API server address
	Master string
	// KubeConfig is an optional path to a kubeconfig file
	KubeConfig string
	// ResyncPeriod is how often the controllers should resync their caches
	ResyncPeriod time.Duration
	// ConfigDir is the base directory for additional Pilot configuration
	ConfigDir string

	// JolokiaURL is the base URL of the Jolokia REST API server.
	JolokiaURL string

	// GenericPilotOptions contains options for the genericpilot
	GenericPilotOptions *genericpilot.Options

	StdOut io.Writer
	StdErr io.Writer
	// contains filtered or unexported fields
}

PilotOptions are the options required to run this Pilot. This can be used to instantiate new instances of the Pilot.

func NewOptions

func NewOptions(out, errOut io.Writer) *PilotOptions

func (*PilotOptions) AddFlags

func (o *PilotOptions) AddFlags(flags *pflag.FlagSet)

func (*PilotOptions) Complete

func (o *PilotOptions) Complete() error

func (*PilotOptions) Run

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

func (*PilotOptions) Validate

func (o *PilotOptions) Validate() error