elasticsearch

Documentation

Index

• func ElasticsearchStatus(kclient kubernetes.Interface, el *v1alpha1.Elasticsearch) (map[string]*v1alpha1.ElasticsearchStatus, map[string][]v1.Pod, error)
• func ListOptions(name string) metav1.ListOptions
• type ConfigMapReference
• type ConfigMapReferenceList
  • func (l *ConfigMapReferenceList) Len() int
  • func (l *ConfigMapReferenceList) Less(i, j int) bool
  • func (l *ConfigMapReferenceList) Swap(i, j int)
• type Operator
  • func New(conf config.Config, logger log.Logger) (*Operator, error)
  • func (c *Operator) Run(stopc <-chan struct{}) error

Functions

func ElasticsearchStatus

func ElasticsearchStatus(kclient kubernetes.Interface, el *v1alpha1.Elasticsearch) (map[string]*v1alpha1.ElasticsearchStatus, map[string][]v1.Pod, error)

ElasticsearchStatus evaluates the current status of a Elasticsearch deployment with respect to its specified resource object. It return the status and a list of pods that are not updated.

func ListOptions

func ListOptions(name string) metav1.ListOptions

Types

type ConfigMapReference

type ConfigMapReference struct {
	Key      string `json:"key"`
	Checksum string `json:"checksum"`
}

type ConfigMapReferenceList

type ConfigMapReferenceList struct {
	Items []*ConfigMapReference `json:"items"`
}

func (*ConfigMapReferenceList) Len

func (l *ConfigMapReferenceList) Len() int

func (*ConfigMapReferenceList) Less

func (l *ConfigMapReferenceList) Less(i, j int) bool

func (*ConfigMapReferenceList) Swap

func (l *ConfigMapReferenceList) Swap(i, j int)

type Operator

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

Operator manages life cycle of Elasticsearch deployments and monitoring configurations.

func New

func New(conf config.Config, logger log.Logger) (*Operator, error)

New creates a new controller.

func (*Operator) Run

func (c *Operator) Run(stopc <-chan struct{}) error

Run the controller.