Misc changes

* Add metric for batch size (how many entries are added to the write queue) * Remove `OstrichProcessor` from default processors Author: @franklinhu Pull Request: #35 URL: #35
openzipkin · Jun 18, 2012 · dc22e0e · dc22e0e
1 parent 7602367
commit dc22e0e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/zipkin-scribe/src/main/scala/com/twitter/zipkin/collector/ScribeCollectorService.scala b/zipkin-scribe/src/main/scala/com/twitter/zipkin/collector/ScribeCollectorService.scala
@@ -95,6 +95,7 @@ class ScribeCollectorService(config: ZipkinCollectorConfig, val writeQueue: Writ
       Ok
     } else if (writeQueue.add(scribeMessages)) {
       Stats.incr("collector.batches_added_to_queue")
+      Stats.addMetric("collector.batch_size", scribeMessages.size)
       Ok
     } else {
       Stats.incr("collector.pushback")

diff --git a/zipkin-server/src/main/scala/com/twitter/zipkin/config/ZipkinCollectorConfig.scala b/zipkin-server/src/main/scala/com/twitter/zipkin/config/ZipkinCollectorConfig.scala
@@ -108,8 +108,7 @@ trait ZipkinCollectorConfig extends ZipkinConfig[ZipkinCollector] {
     new SequenceProcessor[Span](
       new FanoutProcessor[Span]({
         new StorageProcessor(storage) ::
-        new IndexProcessor(index, indexingFilter) ::
-        new OstrichProcessor(serviceStatsPrefix)
+        new IndexProcessor(index, indexingFilter)
       })
     )