org.apache.accumulo.cloudtrace.instrument.receivers
Class ZooSpanClient

java.lang.Object
  extended by org.apache.accumulo.cloudtrace.instrument.receivers.AsyncSpanReceiver<String,SpanReceiver.Client>
      extended by org.apache.accumulo.cloudtrace.instrument.receivers.SendSpansViaThrift
          extended by org.apache.accumulo.cloudtrace.instrument.receivers.ZooSpanClient
All Implemented Interfaces:
SpanReceiver

public class ZooSpanClient
extends SendSpansViaThrift

Find a Span collector via zookeeper and push spans there via Thrift RPC


Field Summary
 
Fields inherited from class org.apache.accumulo.cloudtrace.instrument.receivers.AsyncSpanReceiver
host, service
 
Constructor Summary
ZooSpanClient(String keepers, String path, String host, String service, long millis)
           
 
Method Summary
 void flush()
           
protected  String getSpanKey(Map<String,String> data)
           
 
Methods inherited from class org.apache.accumulo.cloudtrace.instrument.receivers.SendSpansViaThrift
createDestination, send
 
Methods inherited from class org.apache.accumulo.cloudtrace.instrument.receivers.AsyncSpanReceiver
span
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZooSpanClient

public ZooSpanClient(String keepers,
                     String path,
                     String host,
                     String service,
                     long millis)
              throws IOException,
                     org.apache.zookeeper.KeeperException,
                     InterruptedException
Throws:
IOException
org.apache.zookeeper.KeeperException
InterruptedException
Method Detail

flush

public void flush()
Specified by:
flush in interface SpanReceiver
Overrides:
flush in class AsyncSpanReceiver<String,SpanReceiver.Client>

getSpanKey

protected String getSpanKey(Map<String,String> data)
Overrides:
getSpanKey in class SendSpansViaThrift


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.