v3

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 8, 2018 License: Apache-2.0 Imports: 22 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL