Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + type KafkaSpanProcessor struct + func NewSpanProcessor(params SpanProcessorParams) *KafkaSpanProcessor + func (s KafkaSpanProcessor) Process(message Message) error + type Message interface + Value func() []byte + type ParallelProcessor struct + func NewParallelProcessor(processor SpanProcessor, parallelism int, logger *zap.Logger) *ParallelProcessor + func (k *ParallelProcessor) Close() error + func (k *ParallelProcessor) Process(message Message) error + func (k *ParallelProcessor) Start() + type SpanProcessor interface + Process func(input Message) error + func NewDecoratedProcessor(f metrics.Factory, processor SpanProcessor) SpanProcessor + type SpanProcessorParams struct + Unmarshaller kafka.Unmarshaller + Writer spanstore.Writer
Go to main page