traces

Documentation

Index

• func DefaultFunctions() map[string]interface{}
• type Processor
  • func NewProcessor(statements []string, functions map[string]interface{}, ...) (*Processor, error)
  • func (p *Processor) ProcessTraces(_ context.Context, td pdata.Traces) (pdata.Traces, error)
• type Query
  • func Parse(statements []string, functions map[string]interface{}) ([]Query, error)

Functions

func DefaultFunctions

func DefaultFunctions() map[string]interface{}

Types

type Processor

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

func NewProcessor

func NewProcessor(statements []string, functions map[string]interface{}, settings component.ProcessorCreateSettings) (*Processor, error)

func (*Processor) ProcessTraces

func (p *Processor) ProcessTraces(_ context.Context, td pdata.Traces) (pdata.Traces, error)

type Query

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

Query holds a top level Query for processing trace data. A Query is a combination of a function invocation and the condition to match telemetry for invoking the function.

func Parse

func Parse(statements []string, functions map[string]interface{}) ([]Query, error)