Package com.github.kristofa.brave

Class AbstractSpanCollector

java.lang.Object

com.github.kristofa.brave.FlushingSpanCollector

com.github.kristofa.brave.AbstractSpanCollector

All Implemented Interfaces:

SpanCollector

Deprecated.

replaced by AsyncReporter

@Deprecated
public abstract class AbstractSpanCollector
extends FlushingSpanCollector

Implemented sendSpans(byte[]) to transport a encoded list of spans to Zipkin.

Constructor Summary

Constructors

Constructor	Description
AbstractSpanCollector(SpanCodec codec, SpanCollectorMetricsHandler metrics, int flushInterval)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected void	reportSpans(java.util.List<Span> drained)	Deprecated. Reports a list of spans over the current transport.
protected abstract void	sendSpans(byte[] encoded)	Deprecated. Sends a encoded list of spans over the current transport.

Methods inherited from class com.github.kristofa.brave.FlushingSpanCollector

addDefaultAnnotation, close, collect, flush

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractSpanCollector

public AbstractSpanCollector(SpanCodec codec,
                             SpanCollectorMetricsHandler metrics,
                             int flushInterval)

Deprecated.

Parameters:

flushInterval - in seconds. 0 implies spans are flushed externally.

Method Detail

reportSpans

protected void reportSpans(java.util.List<Span> drained)
                    throws java.io.IOException

Deprecated.

Description copied from class: FlushingSpanCollector

Reports a list of spans over the current transport.

Specified by:

reportSpans in class FlushingSpanCollector

Throws:

java.io.IOException - (or RuntimeException) when thrown, drop metrics will increment accordingly

sendSpans

protected abstract void sendSpans(byte[] encoded)
                           throws java.io.IOException

Deprecated.

Sends a encoded list of spans over the current transport.

Throws:

java.io.IOException - when thrown, drop metrics will increment accordingly