v5

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: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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