storage

Documentation

Index

• func Dependencies(jaeger *v1.Jaeger) []batchv1.Job
• func EnableRollover(spec v1.JaegerStorageSpec) bool
• func GetGRPCPluginInitContainers(jaeger *v1.Jaeger, commonSpec *v1.JaegerCommonSpec) []corev1.Container
• func UpdateGRPCPlugin(jaeger *v1.Jaeger, commonSpec *v1.JaegerCommonSpec)
• 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 GetGRPCPluginInitContainers

func GetGRPCPluginInitContainers(jaeger *v1.Jaeger, commonSpec *v1.JaegerCommonSpec) []corev1.Container

GetGRPCPluginInitContainers returns init containers for grpc-plugin storage.

func UpdateGRPCPlugin

func UpdateGRPCPlugin(jaeger *v1.Jaeger, commonSpec *v1.JaegerCommonSpec)

UpdateGRPCPlugin configures storage grpc-plugin. It adds storage flags, volume and volume mount for the plugin binary.

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