elasticsearch

Documentation

Index

• type ContainersSettings
• type Elasticsearch
• 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) (*Elasticsearch, error)
  • func (eo *ElasticsearchOperator) Inspect(sg *apistructs.ServiceGroup) (*apistructs.ServiceGroup, error)
  • func (eo *ElasticsearchOperator) IsSupported() bool
  • func (eo *ElasticsearchOperator) NodeSetsConvert(svc apistructs.Service, scname string, affinity *corev1.NodeAffinity) NodeSetsSettings
  • func (eo *ElasticsearchOperator) Remove(sg *apistructs.ServiceGroup) error
  • func (eo *ElasticsearchOperator) Update(k8syml interface{}) error
  • func (eo *ElasticsearchOperator) Validate(sg *apistructs.ServiceGroup) error
• type ElasticsearchSpec
• type HttpSettings
• type NodeSetsSettings
• type PodSpecSettings
• type PodTemplateSettings
• type SelfSignedCertificateSettings
• type TlsSettings
• type VolumeClaimSettings
• type VolumeClaimSpecSettings

Types

type ContainersSettings

type ContainersSettings struct {
	Name      string                      `json:"name,omitempty"`
	Env       []corev1.EnvVar             `json:"env,omitempty"`
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
}

type Elasticsearch

type Elasticsearch struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ElasticsearchSpec `json:"spec"`
}

type ElasticsearchAndSecret

type ElasticsearchAndSecret struct {
	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 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) (*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(svc apistructs.Service, scname string, affinity *corev1.NodeAffinity) NodeSetsSettings

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

type ElasticsearchSpec

type ElasticsearchSpec struct {
	Http     HttpSettings       `json:"http,omitempty"`
	Version  string             `json:"version,omitempty"`
	Image    string             `json:"image,omitempty"`
	NodeSets []NodeSetsSettings `json:"nodeSets,omitempty"`
}

type HttpSettings

type HttpSettings struct {
	Tls TlsSettings `json:"tls,omitempty"`
}

HttpSettings

type NodeSetsSettings

type NodeSetsSettings struct {
	Name                 string                `json:"name,omitempty"`
	Count                int                   `json:"count,omitempty"`
	Config               map[string]string     `json:"config,omitempty"`
	PodTemplate          PodTemplateSettings   `json:"podTemplate,omitempty"`
	VolumeClaimTemplates []VolumeClaimSettings `json:"volumeClaimTemplates,omitempty"`
}

NodeSetsSettings

type PodSpecSettings

type PodSpecSettings struct {
	Affinity   *corev1.Affinity     `json:"affinity,omitempty"`
	Containers []ContainersSettings `json:"containers,omitempty"`
}

type PodTemplateSettings

type PodTemplateSettings struct {
	Spec PodSpecSettings `json:"spec,omitempty"`
}

type SelfSignedCertificateSettings

type SelfSignedCertificateSettings struct {
	Disabled bool `json:"disabled,omitempty"`
}

type TlsSettings

type TlsSettings struct {
	SelfSignedCertificate SelfSignedCertificateSettings `json:"selfSignedCertificate,omitempty"`
}

type VolumeClaimSettings

type VolumeClaimSettings struct {
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              VolumeClaimSpecSettings `json:"spec,omitempty"`
}

VolumeClaimSettings for ElasticsearchSpec NodeSetsSettings

type VolumeClaimSpecSettings

type VolumeClaimSpecSettings struct {
	AccessModes      []string                    `json:"accessModes,omitempty"`
	Resources        corev1.ResourceRequirements `json:"resources,omitempty"`
	StorageClassName string                      `json:"storageClassName,omitempty"`
}