v5

Documentation

Index

• type ElasticsearchOptions
  • func (e *ElasticsearchOptions) AddFlags(flags *pflag.FlagSet)
  • func (e *ElasticsearchOptions) Complete() error
  • func (e *ElasticsearchOptions) Validate() []error
• 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) InstallPlugins(pilot *v1alpha1.Pilot) error
  • func (p *Pilot) LivenessCheck() probe.Check
  • func (p *Pilot) ReadinessCheck() probe.Check
  • func (p *Pilot) WaitForCacheSync(stopCh <-chan struct{}) error
  • func (p *Pilot) WriteConfig(pilot *v1alpha1.Pilot) 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 ElasticsearchOptions

type ElasticsearchOptions struct {
	MasterURL string
	// Binary is the name of the elasticsearch binary
	Binary string
	// PluginBinary is the name of the binary used to install plugins
	PluginBinary string
	// ConfigDir is the path to the elasticsearch config directory
	ConfigDir string
	// Roles is a list of ElasticsearchCluster roles this Pilot should use
	Roles []string
	// Plugins is a list of plugins to install for elasticsearch is started
	Plugins []string
}

func (*ElasticsearchOptions) AddFlags

func (e *ElasticsearchOptions) AddFlags(flags *pflag.FlagSet)

func (*ElasticsearchOptions) Complete

func (e *ElasticsearchOptions) Complete() error

func (*ElasticsearchOptions) Validate

func (e *ElasticsearchOptions) Validate() []error

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) InstallPlugins

func (p *Pilot) InstallPlugins(pilot *v1alpha1.Pilot) error

InstallPlugins will install the plugins listed on the Pilot resource. It will not uninstall any plugins that are already installed, but are not listed on the Pilot resource.

func (*Pilot) LivenessCheck

func (p *Pilot) LivenessCheck() probe.Check

func (*Pilot) ReadinessCheck

func (p *Pilot) ReadinessCheck() probe.Check

func (*Pilot) WaitForCacheSync

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

func (*Pilot) WriteConfig

func (p *Pilot) WriteConfig(pilot *v1alpha1.Pilot) 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

	// ElasticsearchOptions contains the elasticsearch-specific options
	ElasticsearchOptions *ElasticsearchOptions
	// 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