support text format

Makefile

@@ -21,4 +21,4 @@ examples:
 	cargo build --example example_hyper
 	cp target/debug/examples/* bin/
 
-.PHONY: all
+.PHONY: all examples

examples/example_embed.rs

@@ -36,7 +36,7 @@ fn main() {
     thread::spawn(move || {
         for _ in 0..10 {
             thread::sleep(Duration::from_millis(500));
-            c2.inc_by(3.14159265358979323846264338327).unwrap();
+            c2.inc();
         }
     });
 

examples/example_hyper.rs

@@ -43,7 +43,7 @@ fn main() {
     thread::spawn(move || {
         loop {
             thread::sleep(Duration::from_millis(300));
-            c2.inc_by(3.14159265358979323846264338327).unwrap();
+            c2.inc();
         }
     });
 

src/registry.rs

@@ -14,7 +14,7 @@
 
 use std::sync::{Arc, RwLock};
 use std::collections::HashMap;
-use std::collections::hash_map::Entry::Vacant;
+use std::collections::hash_map::Entry;
 
 use proto;
 use metrics::Collector;
@@ -69,20 +69,23 @@ impl RegistryCore {
         let mut mf_by_name = HashMap::new();
 
         for c in self.colloctors_by_id.values() {
-            let mf = c.collect();
+            let mut mf = c.collect();
             let name = mf.get_name().to_owned();
-            if let Vacant(entry) = mf_by_name.entry(name.clone()) {
-                entry.insert(mf);
-                continue;
-            }
-
-            let mut existent_mf = mf_by_name.get_mut(&name).unwrap();
-            let mut existent_metrics = existent_mf.mut_metric();
 
-            // TODO: check type.
-            // TODO: check consistency.
-            for metric in mf.get_metric() {
-                existent_metrics.push(metric.clone())
+            match mf_by_name.entry(name) {
+                Entry::Vacant(entry) => {
+                    entry.insert(mf);
+                }
+                Entry::Occupied(mut entry) => {
+                    let mut existent_mf = entry.get_mut();
+                    let mut existent_metrics = existent_mf.mut_metric();
+
+                    // TODO: check type.
+                    // TODO: check consistency.
+                    for metric in mf.take_metric().into_iter() {
+                        existent_metrics.push(metric);
+                    }
+                }
             }
         }
 
@@ -126,7 +129,6 @@ impl Registry {
     }
 }
 
-
 #[cfg(test)]
 mod tests {
     use std::thread;