common

Documentation

Index

• func LoadContextCache(contextCache map[ContextID]*pcommon.Map, context ContextID) *pcommon.Map
• func ResourceFunctions() map[string]ottl.Factory[ottlresource.TransformContext]
• func ScopeFunctions() map[string]ottl.Factory[ottlscope.TransformContext]
• type ContextID
  • func (c *ContextID) UnmarshalText(text []byte) error
• type ContextStatements
  • func (c ContextStatements) GetStatements() []string
• type LogParserCollection
  • func NewLogParserCollection(settings component.TelemetrySettings, options ...LogParserCollectionOption) (*LogParserCollection, error)
  • func (lpc *LogParserCollection) ParseContextStatements(contextStatements ContextStatements) (LogsConsumer, error)
• type LogParserCollectionOption
  • func WithLogErrorMode(errorMode ottl.ErrorMode) LogParserCollectionOption
  • func WithLogParser(functions map[string]ottl.Factory[ottllog.TransformContext]) LogParserCollectionOption
• type LogsConsumer
• type MetricParserCollection
  • func NewMetricParserCollection(settings component.TelemetrySettings, options ...MetricParserCollectionOption) (*MetricParserCollection, error)
  • func (mpc *MetricParserCollection) ParseContextStatements(contextStatements ContextStatements) (MetricsConsumer, error)
• type MetricParserCollectionOption
  • func WithDataPointParser(functions map[string]ottl.Factory[ottldatapoint.TransformContext]) MetricParserCollectionOption
  • func WithMetricErrorMode(errorMode ottl.ErrorMode) MetricParserCollectionOption
  • func WithMetricParser(functions map[string]ottl.Factory[ottlmetric.TransformContext]) MetricParserCollectionOption
• type MetricsConsumer
• type TraceParserCollection
  • func NewTraceParserCollection(settings component.TelemetrySettings, options ...TraceParserCollectionOption) (*TraceParserCollection, error)
  • func (tpc *TraceParserCollection) ParseContextStatements(contextStatements ContextStatements) (TracesConsumer, error)
• type TraceParserCollectionOption
  • func WithSpanEventParser(functions map[string]ottl.Factory[ottlspanevent.TransformContext]) TraceParserCollectionOption
  • func WithSpanParser(functions map[string]ottl.Factory[ottlspan.TransformContext]) TraceParserCollectionOption
  • func WithTraceErrorMode(errorMode ottl.ErrorMode) TraceParserCollectionOption
• type TracesConsumer

Functions

func LoadContextCache

func LoadContextCache(contextCache map[ContextID]*pcommon.Map, context ContextID) *pcommon.Map

LoadContextCache retrieves or creates a context cache map for the given context ID. If the cache is not found, a new map is created and stored in the contextCache map.

func ResourceFunctions

func ResourceFunctions() map[string]ottl.Factory[ottlresource.TransformContext]

func ScopeFunctions

func ScopeFunctions() map[string]ottl.Factory[ottlscope.TransformContext]

Types

type ContextID

type ContextID string

const (
	Resource  ContextID = "resource"
	Scope     ContextID = "scope"
	Span      ContextID = "span"
	SpanEvent ContextID = "spanevent"
	Metric    ContextID = "metric"
	DataPoint ContextID = "datapoint"
	Log       ContextID = "log"
)

func (*ContextID) UnmarshalText

func (c *ContextID) UnmarshalText(text []byte) error

type ContextStatements

type ContextStatements struct {
	Context    ContextID `mapstructure:"context"`
	Conditions []string  `mapstructure:"conditions"`
	Statements []string  `mapstructure:"statements"`

	// `SharedCache` is an experimental feature that may change or be removed in the future.
	// When enabled, it allows the statements cache to be shared across all other groups that share the cache.
	// This feature is not configurable via `mapstructure` and cannot be set in configuration files.
	SharedCache bool `mapstructure:"-"`
}

func (ContextStatements) GetStatements

func (c ContextStatements) GetStatements() []string

type LogParserCollection

type LogParserCollection ottl.ParserCollection[LogsConsumer]

func NewLogParserCollection

func NewLogParserCollection(settings component.TelemetrySettings, options ...LogParserCollectionOption) (*LogParserCollection, error)

func (*LogParserCollection) ParseContextStatements

func (lpc *LogParserCollection) ParseContextStatements(contextStatements ContextStatements) (LogsConsumer, error)

type LogParserCollectionOption

type LogParserCollectionOption ottl.ParserCollectionOption[LogsConsumer]

func WithLogErrorMode

func WithLogErrorMode(errorMode ottl.ErrorMode) LogParserCollectionOption

func WithLogParser

func WithLogParser(functions map[string]ottl.Factory[ottllog.TransformContext]) LogParserCollectionOption

type LogsConsumer

type LogsConsumer interface {
	Context() ContextID
	ConsumeLogs(ctx context.Context, ld plog.Logs, cache *pcommon.Map) error
}

type MetricParserCollection

type MetricParserCollection ottl.ParserCollection[MetricsConsumer]

func NewMetricParserCollection

func NewMetricParserCollection(settings component.TelemetrySettings, options ...MetricParserCollectionOption) (*MetricParserCollection, error)

func (*MetricParserCollection) ParseContextStatements

func (mpc *MetricParserCollection) ParseContextStatements(contextStatements ContextStatements) (MetricsConsumer, error)

type MetricParserCollectionOption

type MetricParserCollectionOption ottl.ParserCollectionOption[MetricsConsumer]

func WithDataPointParser

func WithDataPointParser(functions map[string]ottl.Factory[ottldatapoint.TransformContext]) MetricParserCollectionOption

func WithMetricErrorMode

func WithMetricErrorMode(errorMode ottl.ErrorMode) MetricParserCollectionOption

func WithMetricParser

func WithMetricParser(functions map[string]ottl.Factory[ottlmetric.TransformContext]) MetricParserCollectionOption

type MetricsConsumer

type MetricsConsumer interface {
	Context() ContextID
	ConsumeMetrics(ctx context.Context, md pmetric.Metrics, cache *pcommon.Map) error
}

type TraceParserCollection

type TraceParserCollection ottl.ParserCollection[TracesConsumer]

func NewTraceParserCollection

func NewTraceParserCollection(settings component.TelemetrySettings, options ...TraceParserCollectionOption) (*TraceParserCollection, error)

func (*TraceParserCollection) ParseContextStatements

func (tpc *TraceParserCollection) ParseContextStatements(contextStatements ContextStatements) (TracesConsumer, error)

type TraceParserCollectionOption

type TraceParserCollectionOption ottl.ParserCollectionOption[TracesConsumer]

func WithSpanEventParser

func WithSpanEventParser(functions map[string]ottl.Factory[ottlspanevent.TransformContext]) TraceParserCollectionOption

func WithSpanParser

func WithSpanParser(functions map[string]ottl.Factory[ottlspan.TransformContext]) TraceParserCollectionOption

func WithTraceErrorMode

func WithTraceErrorMode(errorMode ottl.ErrorMode) TraceParserCollectionOption

type TracesConsumer

type TracesConsumer interface {
	Context() ContextID
	ConsumeTraces(ctx context.Context, td ptrace.Traces, cache *pcommon.Map) error
}