storage

Documentation

Index

• func CreateESCerts(jaeger *v1.Jaeger, existingSecrets []corev1.Secret) error
• func Dependencies(jaeger *v1.Jaeger) []batchv1.Job
• func ESSecrets(jaeger *v1.Jaeger) []corev1.Secret
• func EnableRollover(spec v1.JaegerStorageSpec) bool
• func OptionsPrefix(storageType string) string
• func ShouldDeployElasticsearch(s v1.JaegerStorageSpec) bool
• func ValidTypes() []string
• type ElasticsearchDeployment
  • func (ed *ElasticsearchDeployment) Elasticsearch() *esv1.Elasticsearch
  • func (ed *ElasticsearchDeployment) InjectSecretsConfiguration(p *corev1.PodSpec)
  • func (ed *ElasticsearchDeployment) InjectStorageConfiguration(p *corev1.PodSpec)

Functions

func CreateESCerts

func CreateESCerts(jaeger *v1.Jaeger, existingSecrets []corev1.Secret) error

CreateESCerts creates certificates for elasticsearch, jaeger and curator The cert generation is done by shell script. If the certificates are not present on the filesystem the operator injects them from secrets - this allows operator restarts. The script also re-generates expired certificates.

func Dependencies

func Dependencies(jaeger *v1.Jaeger) []batchv1.Job

Dependencies return a list of Jobs that have to be finished before the other components are deployed

func ESSecrets

func ESSecrets(jaeger *v1.Jaeger) []corev1.Secret

ESSecrets assembles a set of secrets related to Elasticsearch

func EnableRollover

func EnableRollover(spec v1.JaegerStorageSpec) bool

EnableRollover returns true if rollover should be enabled

func OptionsPrefix

func OptionsPrefix(storageType string) string

OptionsPrefix returns the options prefix associated with the supplied storage type

func ShouldDeployElasticsearch

func ShouldDeployElasticsearch(s v1.JaegerStorageSpec) bool

ShouldDeployElasticsearch determines whether a new instance of Elasticsearch should be deployed

func ValidTypes

func ValidTypes() []string

ValidTypes returns the list of valid storage types

Types

type ElasticsearchDeployment

type ElasticsearchDeployment struct {
	Jaeger *v1.Jaeger
}

ElasticsearchDeployment represents an ES deployment for Jaeger

func (*ElasticsearchDeployment) Elasticsearch

func (ed *ElasticsearchDeployment) Elasticsearch() *esv1.Elasticsearch

Elasticsearch returns an ES CR for the deployment

func (*ElasticsearchDeployment) InjectSecretsConfiguration

func (ed *ElasticsearchDeployment) InjectSecretsConfiguration(p *corev1.PodSpec)

InjectSecretsConfiguration changes the given spec to include the options for the index cleaner

func (*ElasticsearchDeployment) InjectStorageConfiguration

func (ed *ElasticsearchDeployment) InjectStorageConfiguration(p *corev1.PodSpec)

InjectStorageConfiguration changes the given spec to include ES-related command line options