elasticsearch

Documentation

Index

• Constants
• func ContainerDecorate(c corev1.Container, cluster, secret, clusterDomain string, osType rmeta.OSType) corev1.Container
• func ContainerDecorateIndexCreator(c corev1.Container, replicas, shards int) corev1.Container
• func DecorateEnvironment(c corev1.Container, namespace string, ...) corev1.Container
• func DefaultVolumeMount(osType rmeta.OSType) corev1.VolumeMount
• func ElasticEndpoint() string
• 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, 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 (
	PublicCertSecret = "tigera-secure-es-gateway-http-certs-public"
	UnusedCertSecret = "tigera-secure-es-http-certs-unused"
)

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

Functions

func ContainerDecorate

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

ContainerDecorate is the legacy implementation, which does not support multi-tenancy. Use DecorateEnvironment instead.

func ContainerDecorateIndexCreator

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

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 ElasticEndpoint

func ElasticEndpoint() string

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, 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