elasticsearch

Documentation

Index

• type ElasticsearchAndSecret
• type ElasticsearchOperator
  • func New(k8s addon.K8SUtil, sts addon.StatefulsetUtil, ns addon.NamespaceUtil, ...) *ElasticsearchOperator
  • func (eo *ElasticsearchOperator) Convert(sg *apistructs.ServiceGroup) interface{}
  • func (eo *ElasticsearchOperator) Create(k8syml interface{}) error
  • func (eo *ElasticsearchOperator) Get(namespace, name string) (*elasticsearchv1.Elasticsearch, error)
  • func (eo *ElasticsearchOperator) Inspect(sg *apistructs.ServiceGroup) (*apistructs.ServiceGroup, error)
  • func (eo *ElasticsearchOperator) IsSupported() bool
  • func (eo *ElasticsearchOperator) NodeSetsConvert(sg *apistructs.ServiceGroup, scname string, affinity *corev1.NodeAffinity) elasticsearchv1.NodeSet
  • func (eo *ElasticsearchOperator) Remove(sg *apistructs.ServiceGroup) error
  • func (eo *ElasticsearchOperator) Update(k8syml interface{}) error
  • func (eo *ElasticsearchOperator) Validate(sg *apistructs.ServiceGroup) error

Types

type ElasticsearchAndSecret

type ElasticsearchAndSecret struct {
	elasticsearchv1.Elasticsearch
	corev1.Secret
}

type ElasticsearchOperator

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

func New

func New(k8s addon.K8SUtil,
	sts addon.StatefulsetUtil,
	ns addon.NamespaceUtil,
	service addon.ServiceUtil,
	overcommit addon.OvercommitUtil,
	secret addon.SecretUtil,
	imageSecret addon.ImageSecretUtil,
	client *httpclient.HTTPClient) *ElasticsearchOperator

func (*ElasticsearchOperator) Convert

func (eo *ElasticsearchOperator) Convert(sg *apistructs.ServiceGroup) interface{}

Convert sg to cr, which is kubernetes yaml

func (*ElasticsearchOperator) Create

func (eo *ElasticsearchOperator) Create(k8syml interface{}) error

func (*ElasticsearchOperator) Get

func (eo *ElasticsearchOperator) Get(namespace, name string) (*elasticsearchv1.Elasticsearch, error)

Get get elasticsearchs resource information

func (*ElasticsearchOperator) Inspect

func (eo *ElasticsearchOperator) Inspect(sg *apistructs.ServiceGroup) (*apistructs.ServiceGroup, error)

func (*ElasticsearchOperator) IsSupported

func (eo *ElasticsearchOperator) IsSupported() bool

IsSupported Determine whether to support elasticseatch operator

func (*ElasticsearchOperator) NodeSetsConvert

func (eo *ElasticsearchOperator) NodeSetsConvert(sg *apistructs.ServiceGroup, scname string, affinity *corev1.NodeAffinity) elasticsearchv1.NodeSet

func (*ElasticsearchOperator) Remove

func (eo *ElasticsearchOperator) Remove(sg *apistructs.ServiceGroup) error

func (*ElasticsearchOperator) Update

func (eo *ElasticsearchOperator) Update(k8syml interface{}) error

Update secret The update will not be performed, and a restart is required due to the update of the static password. (You can improve the multi-user authentication through the user management machine with perfect service)

func (*ElasticsearchOperator) Validate

func (eo *ElasticsearchOperator) Validate(sg *apistructs.ServiceGroup) error

Validate Verify the legality of the ServiceGroup transformed from diceyml