Documentation
¶
Index ¶
- type ElasticsearchOptions
- type Pilot
- 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
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) InstallPlugins ¶
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 (*Pilot) ReadinessCheck ¶
func (*Pilot) WaitForCacheSync ¶
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
Click to show internal directories.
Click to hide internal directories.