initialize

Documentation

Index

• Constants
• Variables
• func ClusterLogForwarder(spec obs.ClusterLogForwarder, migrateContext utils.Options) obs.ClusterLogForwarder
• func GenerateLokiSpec(ls *obs.LokiStack, tenant string) *obs.Loki
• func GenerateOtlpSpec(ls *obs.LokiStack, tenant string) *obs.OTLP
• func GenerateOutput(outSpec obs.OutputSpec, input, tenant string) obs.OutputSpec
• func MigrateInputs(spec obs.ClusterLogForwarder, options utils.Options) obs.ClusterLogForwarder
• func MigrateLokiStack(spec obs.ClusterLogForwarder, options utils.Options) obs.ClusterLogForwarder
• func ProcessForwarderPipelines(spec obs.ClusterLogForwarderSpec) ([]obs.OutputSpec, []obs.PipelineSpec)
• func Resources(forwarder obs.ClusterLogForwarder, options utils.Options) obs.ClusterLogForwarder

Constants

const (

	// GeneratedSecrets identifies the list of secrets that may not exist but should be considered when configuration and
	// deploying the collector
	GeneratedSecrets = "generatedSecrets"
)

Variables

var (
	DefaultRequestMemory = resource.MustParse("64Mi")
	DefaultRequestCpu    = resource.MustParse("500m")
	DefaultLimitMemory   = resource.MustParse("2048Mi")
	DefaultLimitCpu      = resource.MustParse("6000m")
)

Functions

func ClusterLogForwarder

func ClusterLogForwarder(spec obs.ClusterLogForwarder, migrateContext utils.Options) obs.ClusterLogForwarder

ClusterLogForwarder initializes the forwarder for fields that must be set and are inferred from settings already defined. It additionally takes a context to pass decisions back such as secrets for receiver inputs that will exist after reconciliation but may not exist when the configuration is being generated

func GenerateLokiSpec

func GenerateLokiSpec(ls *obs.LokiStack, tenant string) *obs.Loki

GenerateLokiSpec generates and returns a Loki spec for the defined lokistack output

func GenerateOtlpSpec

func GenerateOtlpSpec(ls *obs.LokiStack, tenant string) *obs.OTLP

GenerateOtlpSpec generates and returns an OTLP spec for the defined lokistack output Note: OTLP does not support compression type `snappy` where loki does This also does not support LabelKeys

func GenerateOutput

func GenerateOutput(outSpec obs.OutputSpec, input, tenant string) obs.OutputSpec

GenerateOutput returns either a Loki or OTLP output spec when migrating Lokistacks

func MigrateInputs

func MigrateInputs(spec obs.ClusterLogForwarder, options utils.Options) obs.ClusterLogForwarder

MigrateInputs creates instances of inputSpec when a pipeline references one of the reserved input names (e.g. application) This function is destructive and replaces any inputs that use the reserved input names

func MigrateLokiStack

func MigrateLokiStack(spec obs.ClusterLogForwarder, options utils.Options) obs.ClusterLogForwarder

MigrateLokiStack migrates a lokistack output into appropriate loki or OTLP outputs based on defined inputs

func ProcessForwarderPipelines

func ProcessForwarderPipelines(spec obs.ClusterLogForwarderSpec) ([]obs.OutputSpec, []obs.PipelineSpec)

ProcessForwarderPipelines migrates the specified output type and name to appropriate outputs and pipelines

func Resources

func Resources(forwarder obs.ClusterLogForwarder, options utils.Options) obs.ClusterLogForwarder