processor

package

v1.17.0 Latest Latest Go to latest Published: Feb 24, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KafkaSpanProcessor struct {
	io.Closer
	// contains filtered or unexported fields
}

KafkaSpanProcessor implements SpanProcessor for Kafka messages

func NewSpanProcessor(params SpanProcessorParams) *KafkaSpanProcessor

NewSpanProcessor creates a new KafkaSpanProcessor

func (s KafkaSpanProcessor) Process(message Message) error

Process unmarshals and writes a single kafka message

type Message interface {
	Value() []byte
}

Message contains the fields of the kafka message that the span processor uses

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

ParallelProcessor is a processor that processes in parallel using a pool of goroutines

func NewParallelProcessor(
	processor SpanProcessor,
	parallelism int,
	logger *zap.Logger) *ParallelProcessor

NewParallelProcessor creates a new parallel processor

func (k *ParallelProcessor) Close() error

Close terminates all running goroutines

func (k *ParallelProcessor) Process(message Message) error

Process queues a message for processing

func (k *ParallelProcessor) Start()

Start begins processing queued messages

type SpanProcessor interface {
	Process(input Message) error
	io.Closer
}

SpanProcessor processes kafka spans

func NewDecoratedProcessor(f metrics.Factory, processor SpanProcessor) SpanProcessor

NewDecoratedProcessor returns a processor with metrics

type SpanProcessorParams struct {
	Writer       spanstore.Writer
	Unmarshaller kafka.Unmarshaller
}

SpanProcessorParams stores the necessary parameters for a SpanProcessor

Path	Synopsis
decorator
mocks