storage

Documentation

Index

• func Dependencies(jaeger *v1.Jaeger) []batchv1.Job
• 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) CleanCerts() error
  • func (ed *ElasticsearchDeployment) CreateCerts() error
  • func (ed *ElasticsearchDeployment) Elasticsearch() *esv1.Elasticsearch
  • func (ed *ElasticsearchDeployment) ExtractSecrets() []corev1.Secret
  • func (ed *ElasticsearchDeployment) InjectSecretsConfiguration(p *corev1.PodSpec)
  • func (ed *ElasticsearchDeployment) InjectStorageConfiguration(p *corev1.PodSpec)

Functions

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 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
	CertScript string
	Secrets    []corev1.Secret
}

ElasticsearchDeployment represents an ES deployment for Jaeger

func (*ElasticsearchDeployment) CleanCerts

func (ed *ElasticsearchDeployment) CleanCerts() error

CleanCerts removes certificates from local filesystem. Use this function in tests to clean resources

func (*ElasticsearchDeployment) CreateCerts

func (ed *ElasticsearchDeployment) CreateCerts() error

CreateCerts 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 (*ElasticsearchDeployment) Elasticsearch

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

Elasticsearch returns an ES CR for the deployment

func (*ElasticsearchDeployment) ExtractSecrets

func (ed *ElasticsearchDeployment) ExtractSecrets() []corev1.Secret

ExtractSecrets assembles a set of secrets related to Elasticsearch

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