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
• type LogParserCollection
  • func NewLogParserCollection(settings component.TelemetrySettings, options ...LogParserCollectionOption) (*LogParserCollection, error)
  • func (pc LogParserCollection) ParseContextStatements(contextStatements ContextStatements) (consumer.Logs, error)
• type LogParserCollectionOption
  • func WithLogErrorMode(errorMode ottl.ErrorMode) LogParserCollectionOption
  • func WithLogParser(functions map[string]ottl.Factory[*ottllog.TransformContext]) LogParserCollectionOption
• type MetricParserCollection
  • func NewMetricParserCollection(settings component.TelemetrySettings, options ...MetricParserCollectionOption) (*MetricParserCollection, error)
  • func (pc MetricParserCollection) ParseContextStatements(contextStatements ContextStatements) (consumer.Metrics, 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 TraceParserCollection
  • func NewTraceParserCollection(settings component.TelemetrySettings, options ...TraceParserCollectionOption) (*TraceParserCollection, error)
  • func (pc TraceParserCollection) ParseContextStatements(contextStatements ContextStatements) (consumer.Traces, 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

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"
)

func (*ContextID) UnmarshalText

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

type ContextStatements

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

type LogParserCollection

type LogParserCollection struct {
	// contains filtered or unexported fields
}

func NewLogParserCollection

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

func (LogParserCollection) ParseContextStatements

func (pc LogParserCollection) ParseContextStatements(contextStatements ContextStatements) (consumer.Logs, error)

type LogParserCollectionOption

type LogParserCollectionOption func(*LogParserCollection) error

func WithLogErrorMode

func WithLogErrorMode(errorMode ottl.ErrorMode) LogParserCollectionOption

func WithLogParser

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

type MetricParserCollection

type MetricParserCollection struct {
	// contains filtered or unexported fields
}

func NewMetricParserCollection

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

func (MetricParserCollection) ParseContextStatements

func (pc MetricParserCollection) ParseContextStatements(contextStatements ContextStatements) (consumer.Metrics, error)

type MetricParserCollectionOption

type MetricParserCollectionOption func(*MetricParserCollection) error

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 TraceParserCollection

type TraceParserCollection struct {
	// contains filtered or unexported fields
}

func NewTraceParserCollection

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

func (TraceParserCollection) ParseContextStatements

func (pc TraceParserCollection) ParseContextStatements(contextStatements ContextStatements) (consumer.Traces, error)

type TraceParserCollectionOption

type TraceParserCollectionOption func(*TraceParserCollection) error

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