span

Documentation

Index

• func ExtractTracingSpanMappingDocs() *service.ConfigField
• func NewBatchInput(inputName string, pConf *service.ParsedConfig, rdr service.BatchInput, ...) (service.BatchInput, error)
• func NewInput(inputName string, pConf *service.ParsedConfig, rdr service.Input, ...) (service.Input, error)

Functions

func ExtractTracingSpanMappingDocs

func ExtractTracingSpanMappingDocs() *service.ConfigField

ExtractTracingSpanMappingDocs returns a docs spec for a mapping field.

func NewBatchInput

func NewBatchInput(inputName string, pConf *service.ParsedConfig, rdr service.BatchInput, mgr *service.Resources) (service.BatchInput, error)

NewBatchInput wraps a service.BatchInput with a mechanism for extracting tracing spans from the consumed message using a Bloblang mapping.

func NewInput

func NewInput(inputName string, pConf *service.ParsedConfig, rdr service.Input, mgr *service.Resources) (service.Input, error)

NewInput wraps a service.Input with a mechanism for extracting tracing spans from the consumed message using a Bloblang mapping.