Switch internal telemetry to Sum from Set (#403)

This commit changes our internal telemetry to be aggregated as a
Sum instead of a Set by default. This brings the cheap telemetry
in-line with the report_full_telemetry aggregation. Additionally,
the value is no longer reset to zero after reads.

Resolves #402

Signed-off-by: Brian L. Troutwine <blt@postmates.com>

src/metric/telemetry.rs

@@ -524,7 +524,7 @@ impl Telemetry {
     /// # Examples
     ///
     /// ```
-    /// use cernan::metric::{Telemetry,AggregationMethod};
+    /// use cernan::metric::{AggregationMethod, Telemetry};
     ///
     /// let m = Telemetry::new().name("foo").value(1.1).harden().unwrap();
     ///
@@ -622,7 +622,7 @@ impl Telemetry {
     /// # Examples
     ///
     /// ```
-    /// use cernan::metric::{Telemetry,TagMap};
+    /// use cernan::metric::{TagMap, Telemetry};
     ///
     /// let mut m = Telemetry::new().name("foo").value(1.1).harden().unwrap();
     ///
@@ -656,7 +656,7 @@ impl Telemetry {
     /// # Examples
     ///
     /// ```
-    /// use cernan::metric::{Telemetry,TagMap};
+    /// use cernan::metric::{TagMap, Telemetry};
     ///
     /// let mut m = Telemetry::new().name("foo").value(1.1).harden().unwrap();
     ///
@@ -901,8 +901,12 @@ impl Telemetry {
     /// ```
     /// use cernan::metric::Telemetry;
     ///
-    /// let m = Telemetry::new().name("foo").value(1.1).harden().unwrap().
-    /// timestamp(10101);
+    /// let m = Telemetry::new()
+    ///     .name("foo")
+    ///     .value(1.1)
+    ///     .harden()
+    ///     .unwrap()
+    ///     .timestamp(10101);
     ///
     /// assert_eq!(10101, m.timestamp);
     /// ```

src/sink/kinesis.rs

@@ -54,7 +54,7 @@ fn connect(
 ) -> Box<KinesisClient<DefaultCredentialsProvider, hyper::client::Client>> {
     let tls = default_tls_client().unwrap();
     let provider = DefaultCredentialsProvider::new().unwrap();
-    return Box::new(KinesisClient::new(tls, provider, region));
+    Box::new(KinesisClient::new(tls, provider, region))
 }
 
 /// Kinesis sink internal state.

src/sink/native.rs

@@ -125,7 +125,9 @@ impl Sink<NativeConfig> for Native {
                         metric::AggregationMethod::Histogram => AggregationMethod::BIN,
                         metric::AggregationMethod::Sum => AggregationMethod::SUM,
                         metric::AggregationMethod::Set => AggregationMethod::SET,
-                        metric::AggregationMethod::Summarize => AggregationMethod::SUMMARIZE,
+                        metric::AggregationMethod::Summarize => {
+                            AggregationMethod::SUMMARIZE
+                        }
                     };
                     let persist = m.persist;
                     telem.set_persisted(persist);