elasticsearch

Documentation

Index

• Constants
• func ContainerDecorate(c corev1.Container, cluster, secret, clusterDomain string, osType rmeta.OSType) corev1.Container
• func ContainerDecorateENVVars(c corev1.Container, cluster, esUserSecretName, clusterDomain string, ...) corev1.Container
• func ContainerDecorateIndexCreator(c corev1.Container, replicas, shards int) corev1.Container
• func ContainerDecorateVolumeMounts(c corev1.Container, osType rmeta.OSType) corev1.Container
• func DefaultVolume() corev1.Volume
• func DefaultVolumeMount(osType rmeta.OSType) corev1.VolumeMount
• func HTTPSEndpoint(osType rmeta.OSType, clusterDomain string) string
• func PodSpecDecorate(p corev1.PodSpec) corev1.PodSpec
• type Annotatable
  • func DecorateAnnotations(obj Annotatable, config *ClusterConfig, secrets []*corev1.Secret) Annotatable
• type ClusterConfig
  • func NewClusterConfig(clusterName string, replicas int, shards int, flowShards int) *ClusterConfig
  • func NewClusterConfigFromConfigMap(configMap *corev1.ConfigMap) (*ClusterConfig, error)
  • func (c ClusterConfig) Annotation() string
  • func (c ClusterConfig) ClusterName() string
  • func (c ClusterConfig) ConfigMap() *corev1.ConfigMap
  • func (c ClusterConfig) FlowShards() int
  • func (c ClusterConfig) Replicas() int
  • func (c ClusterConfig) Shards() int

Constants

const (
	DefaultCertDir         = "/etc/ssl/elastic/"
	DefaultCertDirWindows  = "c:/etc/ssl/elastic/"
	DefaultCertPath        = DefaultCertDir + "ca.pem"
	DefaultCertPathWindows = DefaultCertDirWindows + "ca.pem"
)

const (
	PublicCertSecret   = "tigera-secure-es-gateway-http-certs-public"
	InternalCertSecret = "tigera-secure-es-http-certs-public"
)

const (
	ClusterConfigConfigMapName = "tigera-secure-elasticsearch"
)

Functions

func ContainerDecorate

func ContainerDecorate(c corev1.Container, cluster, secret, clusterDomain string, osType rmeta.OSType) corev1.Container

func ContainerDecorateENVVars

func ContainerDecorateENVVars(
	c corev1.Container,
	cluster, esUserSecretName, clusterDomain string,
	osType rmeta.OSType) corev1.Container

func ContainerDecorateIndexCreator

func ContainerDecorateIndexCreator(c corev1.Container, replicas, shards int) corev1.Container

func ContainerDecorateVolumeMounts

func ContainerDecorateVolumeMounts(c corev1.Container, osType rmeta.OSType) corev1.Container

func DefaultVolume

func DefaultVolume() corev1.Volume

func DefaultVolumeMount

func DefaultVolumeMount(osType rmeta.OSType) corev1.VolumeMount

func HTTPSEndpoint

func HTTPSEndpoint(osType rmeta.OSType, clusterDomain string) string

HTTPSEndpoint returns the endpoint for the Elasticsearch service. For Windows, the FQDN endpoint is returned.

func PodSpecDecorate

func PodSpecDecorate(p corev1.PodSpec) corev1.PodSpec

Types

type Annotatable

type Annotatable interface {
	SetAnnotations(map[string]string)
	GetAnnotations() map[string]string
}

func DecorateAnnotations

func DecorateAnnotations(obj Annotatable, config *ClusterConfig, secrets []*corev1.Secret) Annotatable

type ClusterConfig

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

func NewClusterConfig

func NewClusterConfig(clusterName string, replicas int, shards int, flowShards int) *ClusterConfig

func NewClusterConfigFromConfigMap

func NewClusterConfigFromConfigMap(configMap *corev1.ConfigMap) (*ClusterConfig, error)

func (ClusterConfig) Annotation

func (c ClusterConfig) Annotation() string

func (ClusterConfig) ClusterName

func (c ClusterConfig) ClusterName() string

func (ClusterConfig) ConfigMap

func (c ClusterConfig) ConfigMap() *corev1.ConfigMap

func (ClusterConfig) FlowShards

func (c ClusterConfig) FlowShards() int

func (ClusterConfig) Replicas

func (c ClusterConfig) Replicas() int

func (ClusterConfig) Shards

func (c ClusterConfig) Shards() int