elasticsearch

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: 32 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ControlInterface

type ControlInterface interface {
	Sync(*v1alpha1.ElasticsearchCluster) (v1alpha1.ElasticsearchClusterStatus, error)
}

func NewController

func NewController(
	kubeClient kubernetes.Interface,
	navigatorClient clientset.Interface,
	statefulSetLister appslisters.StatefulSetLister,
	serviceAccountLister corelisters.ServiceAccountLister,
	serviceLister corelisters.ServiceLister,
	configMapLister corelisters.ConfigMapLister,
	pilotLister listers.PilotLister,
	podLister corelisters.PodLister,
	configMapControl configmap.Interface,
	serviceAccountControl serviceaccount.Interface,
	serviceControl service.Interface,
	roleControl role.Interface,
	roleBindingControl rolebinding.Interface,
	recorder record.EventRecorder,
) ControlInterface

type ElasticsearchController

type ElasticsearchController struct {
	// contains filtered or unexported fields
}

func NewElasticsearch

NewElasticsearch returns a new ElasticsearchController that can be used to monitor for Elasticsearch resources and create clusters in a target Kubernetes cluster.

It accepts a list of informers that are then used to monitor the state of the target cluster.

func (*ElasticsearchController) Run

func (e *ElasticsearchController) Run(workers int, stopCh <-chan struct{}) error

Run is the main event loop

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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