common

Documentation

Index

• 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 ProfileParserCollection
  • func NewProfileParserCollection(settings component.TelemetrySettings, options ...ProfileParserCollectionOption) (*ProfileParserCollection, error)
  • func (ppc *ProfileParserCollection) ParseContextStatements(contextStatements ContextStatements) (ProfilesConsumer, error)
• type ProfileParserCollectionOption
  • func WithProfileErrorMode(errorMode ottl.ErrorMode) ProfileParserCollectionOption
  • func WithProfileParser(functions map[string]ottl.Factory[ottlprofile.TransformContext]) ProfileParserCollectionOption
• type ProfilesConsumer
• 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 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"
	Profile   ContextID = "profile"
)

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"`
	// ErrorMode determines how the processor reacts to errors that occur while processing
	// this group of statements. When provided, it overrides the default Config ErrorMode.
	ErrorMode ottl.ErrorMode `mapstructure:"error_mode"`
}

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) 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) error
}

type ProfileParserCollection

type ProfileParserCollection ottl.ParserCollection[ProfilesConsumer]

func NewProfileParserCollection

func NewProfileParserCollection(settings component.TelemetrySettings, options ...ProfileParserCollectionOption) (*ProfileParserCollection, error)

func (*ProfileParserCollection) ParseContextStatements

func (ppc *ProfileParserCollection) ParseContextStatements(contextStatements ContextStatements) (ProfilesConsumer, error)

type ProfileParserCollectionOption

type ProfileParserCollectionOption ottl.ParserCollectionOption[ProfilesConsumer]

func WithProfileErrorMode

func WithProfileErrorMode(errorMode ottl.ErrorMode) ProfileParserCollectionOption

func WithProfileParser

func WithProfileParser(functions map[string]ottl.Factory[ottlprofile.TransformContext]) ProfileParserCollectionOption

type ProfilesConsumer

type ProfilesConsumer interface {
	Context() ContextID
	ConsumeProfiles(ctx context.Context, ld pprofile.Profiles) 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) error
}