sourcegraph
diff --git a/‎python/appdash/event.py‎
Lines changed: 14 additions & 1 deletion b/‎python/appdash/event.py‎
Lines changed: 14 additions & 1 deletion
diff --git a/‎python/appdash/recorder.py‎
Lines changed: 37 additions & 0 deletions b/‎python/appdash/recorder.py‎
Lines changed: 37 additions & 0 deletions
diff --git a/‎python/setup.py‎
Lines changed: 1 addition & 0 deletions b/‎python/setup.py‎
Lines changed: 1 addition & 0 deletions
@@ -63,6 +63,19 @@ def __init__(self, msg):
     def marshal(self):
         return {"Msg": self.msg, "Time": self.time}
 
+class TimespanEvent:
+
+    schema = "Timespan"
+    start = ""
+    end = ""
+
+    def __init__(self, start, end):
+        self.start = timeString(start)
+        self.end = timeString(end)
+
+    def marshal(self)
+        return {"Span.Start": self.start, "Span.End": self.end}
+
 # SQLEvent is an SQL query event with send and receive times, as well as the
 # actual SQL that was ran, and a optional tag.
 class SQLEvent:
@@ -71,7 +84,7 @@ class SQLEvent:
     # sql is literally the SQL query that was ran.
     sql = ""
 
-    # tag is a optional user-created tag associated with the SQL event. 
+    # tag is a optional user-created tag associated with the SQL event.
     tag = ""
 
     # RFC3339-UTC timestamp of when the query was sent, and later a result received.
 
@@ -0,0 +1,37 @@
+from spanid import SpanID, Annotation
+
+class AppdashRecorder(object):
+    def __init__(self, collector):
+        self._collector = collector
+
+    def record_span(self, span):
+        if not span.context.sampled:
+            return
+        annotations = []
+        span_id = SpanID()
+        span_id.trace = span.context.trace_id
+        span_id.span = span.context.span
+        span_id.parent = span.context.parent_span_id
+
+        # It might not be right to build a list, maybe send events one at a time.
+        annotations.append(MarshalEvent(SpanNameEvent(span.operation_name)))
+
+        approx_endtime = span.context.start_time + span.duration
+        annotations.append(MarshalEvent(
+            TimespanEvent(span.context.start_time, approx_endtime)))
+
+        for key in span.tags:
+            annotations.append(Annotation(key, span.tag[key])
+
+        for key in span.context.baggage_items:
+            annotations.append(Annotation(key, span.contex.baggage_items[value])
+
+        self._collector.collect(span_id, events)
+
+
+class AppdashTracer(BasicTracer):
+
+    def __init__(self, collector, sampler=None):
+        self._recorder = AppdashRecorder(collector)
+        super(AppdashTracer, self).__init__(recorder=self._recorder,
+                                            sampler=sampler)
@@ -10,4 +10,5 @@
     author_email = 'hi@sourcegraph.com',
     url = 'https://sourcegraph.com/sourcegraph/appdash',
     packages = ['appdash'],
+    install_requires = ['basictracer'],
 )
Original file line number	Diff line number	Diff line change
`@@ -10,4 +10,5 @@`
`10`	`10`	`author_email = 'hi@sourcegraph.com',`
`11`	`11`	`url = 'https://sourcegraph.com/sourcegraph/appdash',`
`12`	`12`	`packages = ['appdash'],`
	`13`	`+ install_requires = ['basictracer'],`
`13`	`14`	`)`