common

Documentation

Index

• func FilterAndSortProcessorsByOrderHint(processors *odigosv1.ProcessorList, collectorRole odigosv1.CollectorsGroupRole) []*odigosv1.Processor
• func FindFirstProcessorByType(allProcessors *odigosv1.ProcessorList, processorType string) *odigosv1.Processor
• func GetCollectorsGroupDeployedConditionsPatch(err error) string
• func GetGenericBatchProcessor() odigosv1.Processor
• func GetMemoryLimiterConfig(memorySettings odigosv1.CollectorsGroupResourcesSettings) config.GenericMap
• func Sha256Hash(value string) string
• func ToExporterConfigurerArray(dests *odigosv1.DestinationList) []config.ExporterConfigurer
• func ToProcessorConfigurerArray(items []*odigosv1.Processor) []config.ProcessorConfigurer
• func UpdateCollectorGroupReceiverSignals(ctx context.Context, c client.Client, cg *odigosv1.CollectorsGroup, ...) error

Functions

func FilterAndSortProcessorsByOrderHint

func FilterAndSortProcessorsByOrderHint(processors *odigosv1.ProcessorList, collectorRole odigosv1.CollectorsGroupRole) []*odigosv1.Processor

func FindFirstProcessorByType

func FindFirstProcessorByType(allProcessors *odigosv1.ProcessorList, processorType string) *odigosv1.Processor

func GetCollectorsGroupDeployedConditionsPatch

func GetCollectorsGroupDeployedConditionsPatch(err error) string

func GetGenericBatchProcessor

func GetGenericBatchProcessor() odigosv1.Processor

func GetMemoryLimiterConfig

func GetMemoryLimiterConfig(memorySettings odigosv1.CollectorsGroupResourcesSettings) config.GenericMap

func Sha256Hash

func Sha256Hash(value string) string

func ToExporterConfigurerArray

func ToExporterConfigurerArray(dests *odigosv1.DestinationList) []config.ExporterConfigurer

func ToProcessorConfigurerArray

func ToProcessorConfigurerArray(items []*odigosv1.Processor) []config.ProcessorConfigurer

Convenience methods to convert between k8s types and config interfaces

func UpdateCollectorGroupReceiverSignals

func UpdateCollectorGroupReceiverSignals(ctx context.Context, c client.Client, cg *odigosv1.CollectorsGroup, signals []common.ObservabilitySignal) error