elasticsearch

Documentation

Index

• Constants
• func DecorateEnvironment(c corev1.Container, namespace string, ...) corev1.Container
• func DefaultVolumeMount(osType rmeta.OSType) corev1.VolumeMount
• func ECKElasticEndpoint() string
• func ElasticCAEnvVar(osType rmeta.OSType) corev1.EnvVar
• func ElasticCuratorBackendCertEnvVar(osType rmeta.OSType) corev1.EnvVar
• func ElasticHostEnvVar(esHost string) corev1.EnvVar
• func ElasticIndexSuffixEnvVar(esIdxSuffix string) corev1.EnvVar
• func ElasticPasswordEnvVar(esUserSecretName string) corev1.EnvVar
• func ElasticPortEnvVar(esPort string) corev1.EnvVar
• func ElasticSchemeEnvVar(esScheme string) corev1.EnvVar
• func ElasticUserEnvVar(esUserSecretName string) corev1.EnvVar
• func ElasticUsernameEnvVar(esUsernameSecret string) corev1.EnvVar
• func GatewayEndpoint(osType rmeta.OSType, clusterDomain, namespace string) string
• func HTTPSEndpoint(osType rmeta.OSType, clusterDomain string) string
• func LinseedEndpoint(osType rmeta.OSType, clusterDomain, namespace string) string
• type Annotatable
  • func DecorateAnnotations(obj Annotatable, 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) 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 (
	PublicCertSecret = "tigera-secure-es-gateway-http-certs-public"
	UnusedCertSecret = "tigera-secure-es-http-certs-unused"
)

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

Functions

func DecorateEnvironment

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

func DefaultVolumeMount

func DefaultVolumeMount(osType rmeta.OSType) corev1.VolumeMount

func ECKElasticEndpoint

func ECKElasticEndpoint() string

ECKElasticEndpoint returns the URL of the Elasticsearch provisioned by the ECK operator. This endpoint is only valid when using internal elasticsearch.

func ElasticCAEnvVar

func ElasticCAEnvVar(osType rmeta.OSType) corev1.EnvVar

func ElasticCuratorBackendCertEnvVar

func ElasticCuratorBackendCertEnvVar(osType rmeta.OSType) corev1.EnvVar

func ElasticHostEnvVar

func ElasticHostEnvVar(esHost string) corev1.EnvVar

func ElasticIndexSuffixEnvVar

func ElasticIndexSuffixEnvVar(esIdxSuffix string) corev1.EnvVar

func ElasticPasswordEnvVar

func ElasticPasswordEnvVar(esUserSecretName string) corev1.EnvVar

func ElasticPortEnvVar

func ElasticPortEnvVar(esPort string) corev1.EnvVar

func ElasticSchemeEnvVar

func ElasticSchemeEnvVar(esScheme string) corev1.EnvVar

func ElasticUserEnvVar

func ElasticUserEnvVar(esUserSecretName string) corev1.EnvVar

func ElasticUsernameEnvVar

func ElasticUsernameEnvVar(esUsernameSecret string) corev1.EnvVar

func GatewayEndpoint

func GatewayEndpoint(osType rmeta.OSType, clusterDomain, namespace string) string

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

func HTTPSEndpoint

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

Deprecated - does not support multi-tenancy. Use GatewayEndpoint instead.

func LinseedEndpoint

func LinseedEndpoint(osType rmeta.OSType, clusterDomain, namespace string) string

Types

type Annotatable

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

func DecorateAnnotations

func DecorateAnnotations(obj Annotatable, 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) 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