Documentation
¶
Index ¶
- type ContainersSettings
- type Elasticsearch
- type ElasticsearchAndSecret
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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"`
}
Click to show internal directories.
Click to hide internal directories.