common

package
v0.0.0-...-e1bd6cf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 3, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FilterAndSortProcessorsByOrderHint

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

func IsProcessorLogsEnabled

func IsProcessorLogsEnabled(processor *odigosv1.Processor) bool

func IsProcessorMetricsEnabled

func IsProcessorMetricsEnabled(processor *odigosv1.Processor) bool

func IsProcessorTracingEnabled

func IsProcessorTracingEnabled(processor *odigosv1.Processor) bool

func Sha256Hash

func Sha256Hash(value string) string

Types

type Config

type Config struct {
	Receivers  GenericMap `json:"receivers"`
	Exporters  GenericMap `json:"exporters"`
	Processors GenericMap `json:"processors"`
	Extensions GenericMap `json:"extensions"`
	Service    Service    `json:"service"`
}

type GenericMap

type GenericMap map[string]interface{}

func GetCrdProcessorsConfigMap

func GetCrdProcessorsConfigMap(processors *odigosv1.ProcessorList, collectorRole odigosv1.CollectorsGroupRole) (cfg GenericMap, tracesProcessors []string, metricsProcessors []string, logsProcessors []string)

func ProcessorCrToCollectorConfig

func ProcessorCrToCollectorConfig(processor *odigosv1.Processor) (GenericMap, string, error)

type Pipeline

type Pipeline struct {
	Receivers  []string `json:"receivers"`
	Processors []string `json:"processors"`
	Exporters  []string `json:"exporters"`
}

type Service

type Service struct {
	Extensions []string            `json:"extensions"`
	Pipelines  map[string]Pipeline `json:"pipelines"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL