elasticsearch

Documentation

Index

• type ControlInterface
  • func NewController(kubeClient kubernetes.Interface, navigatorClient clientset.Interface, ...) ControlInterface
• type ElasticsearchController
  • func NewElasticsearch(es navigatorinformers.ElasticsearchClusterInformer, ...) *ElasticsearchController
  • func (e *ElasticsearchController) Run(workers int, stopCh <-chan struct{}) error

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

func NewElasticsearch(
	es navigatorinformers.ElasticsearchClusterInformer,
	pilots navigatorinformers.PilotInformer,
	statefulsets appsinformers.StatefulSetInformer,
	pods coreinformers.PodInformer,
	serviceaccounts coreinformers.ServiceAccountInformer,
	services coreinformers.ServiceInformer,
	configmaps coreinformers.ConfigMapInformer,
	roles rbacinformers.RoleInformer,
	rolebindings rbacinformers.RoleBindingInformer,
	cl kubernetes.Interface,
	navigatorCl clientset.Interface,
	recorder record.EventRecorder,
) *ElasticsearchController

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