org.apache.accumulo.trace.instrument.receivers
public abstract class AsyncSpanReceiver<SpanKey,Destination> extends Object implements SpanReceiver
Modifier and Type | Field and Description |
---|---|
protected String |
host |
protected String |
service |
Constructor and Description |
---|
AsyncSpanReceiver(String host,
String service,
long millis) |
Modifier and Type | Method and Description |
---|---|
protected abstract Destination |
createDestination(SpanKey key) |
void |
flush() |
protected abstract SpanKey |
getSpanKey(Map<String,String> data) |
protected abstract void |
send(Destination resource,
RemoteSpan span) |
void |
span(long traceId,
long spanId,
long parentId,
long start,
long stop,
String description,
Map<String,String> data) |
protected abstract Destination createDestination(SpanKey key) throws Exception
Exception
protected abstract void send(Destination resource, RemoteSpan span) throws Exception
Exception
public void span(long traceId, long spanId, long parentId, long start, long stop, String description, Map<String,String> data)
span
in interface SpanReceiver
public void flush()
flush
in interface SpanReceiver
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.