Fix typos in multiple files. (#188)

README.md

@@ -60,8 +60,8 @@ counter.inc();
 // Gather the metrics.
 let mut buffer = vec![];
 let encoder = TextEncoder::new();
-let metric_familys = r.gather();
-encoder.encode(&metric_familys, &mut buffer).unwrap();
+let metric_families = r.gather();
+encoder.encode(&metric_families, &mut buffer).unwrap();
 
 // Output to the standard output.
 println!("{}", String::from_utf8(buffer).unwrap());

examples/example_embed.rs

@@ -95,8 +95,8 @@ fn main() {
     let mut buffer = Vec::<u8>::new();
     let encoder = TextEncoder::new();
     for _ in 0..5 {
-        let metric_familys = r.gather();
-        encoder.encode(&metric_familys, &mut buffer).unwrap();
+        let metric_families = r.gather();
+        encoder.encode(&metric_families, &mut buffer).unwrap();
 
         // Output to the standard output.
         println!("{}", String::from_utf8(buffer.clone()).unwrap());

examples/example_hyper.rs

@@ -51,9 +51,9 @@ fn main() {
             HTTP_COUNTER.inc();
             let timer = HTTP_REQ_HISTOGRAM.with_label_values(&["all"]).start_timer();
 
-            let metric_familys = prometheus::gather();
+            let metric_families = prometheus::gather();
             let mut buffer = vec![];
-            encoder.encode(&metric_familys, &mut buffer).unwrap();
+            encoder.encode(&metric_families, &mut buffer).unwrap();
             res.headers_mut()
                 .set(ContentType(encoder.format_type().parse::<Mime>().unwrap()));
             res.send(&buffer).unwrap();

examples/example_process_collector.rs

@@ -24,8 +24,8 @@ fn main() {
     let mut buffer = Vec::new();
     let encoder = prometheus::TextEncoder::new();
     for _ in 0..5 {
-        let metric_familys = prometheus::gather();
-        encoder.encode(&metric_familys, &mut buffer).unwrap();
+        let metric_families = prometheus::gather();
+        encoder.encode(&metric_families, &mut buffer).unwrap();
 
         // Output to the standard output.
         println!("{}", String::from_utf8(buffer.clone()).unwrap());

examples/example_push.rs

@@ -63,13 +63,13 @@ fn main() {
     for _ in 0..5 {
         thread::sleep(time::Duration::from_secs(2));
         PUSH_COUNTER.inc();
-        let metric_familys = prometheus::gather();
+        let metric_families = prometheus::gather();
         let _timer = PUSH_REQ_HISTOGRAM.start_timer(); // drop as observe
         prometheus::push_metrics(
             "example_push",
             labels!{"instance".to_owned() => "HAL-9000".to_owned(),},
             &address,
-            metric_familys,
+            metric_families,
             Some(prometheus::BasicAuthentication {
                 username: "user".to_owned(),
                 password: "pass".to_owned(),

src/encoder/pb.rs

@@ -36,8 +36,8 @@ impl ProtobufEncoder {
 }
 
 impl Encoder for ProtobufEncoder {
-    fn encode<W: Write>(&self, metric_familys: &[MetricFamily], writer: &mut W) -> Result<()> {
-        for mf in metric_familys {
+    fn encode<W: Write>(&self, metric_families: &[MetricFamily], writer: &mut W) -> Result<()> {
+        for mf in metric_families {
             // Fail-fast checks.
             check_metric_family(mf)?;
             mf.write_length_delimited_to_writer(writer)?;

src/encoder/text.rs

@@ -37,8 +37,8 @@ impl TextEncoder {
 }
 
 impl Encoder for TextEncoder {
-    fn encode<W: Write>(&self, metric_familys: &[MetricFamily], writer: &mut W) -> Result<()> {
-        for mf in metric_familys {
+    fn encode<W: Write>(&self, metric_families: &[MetricFamily], writer: &mut W) -> Result<()> {
+        for mf in metric_families {
             // Fail-fast checks.
             check_metric_family(mf)?;
 

src/registry.rs

@@ -25,7 +25,7 @@ use metrics::Collector;
 use proto;
 
 struct RegistryCore {
-    pub colloctors_by_id: HashMap<u64, Box<Collector>>,
+    pub collectors_by_id: HashMap<u64, Box<Collector>>,
     pub dim_hashes_by_name: HashMap<String, u64>,
     pub desc_ids: HashSet<u64>,
 }
@@ -78,7 +78,7 @@ impl RegistryCore {
             }
         }
 
-        match self.colloctors_by_id.entry(collector_id) {
+        match self.collectors_by_id.entry(collector_id) {
             HEntry::Vacant(vc) => {
                 self.desc_ids.extend(desc_id_set);
                 vc.insert(c);
@@ -98,7 +98,7 @@ impl RegistryCore {
             }
         }
 
-        if self.colloctors_by_id.remove(&collector_id).is_none() {
+        if self.collectors_by_id.remove(&collector_id).is_none() {
             return Err(Error::Msg(format!(
                 "collector {:?} is not registered",
                 c.desc()
@@ -113,7 +113,7 @@ impl RegistryCore {
     fn gather(&self) -> Vec<proto::MetricFamily> {
         let mut mf_by_name = BTreeMap::new();
 
-        for c in self.colloctors_by_id.values() {
+        for c in self.collectors_by_id.values() {
             let mfs = c.collect();
             for mut mf in mfs {
                 // Prune empty MetricFamilies.
@@ -191,7 +191,7 @@ pub struct Registry {
 impl Default for Registry {
     fn default() -> Registry {
         let r = RegistryCore {
-            colloctors_by_id: HashMap::new(),
+            collectors_by_id: HashMap::new(),
             dim_hashes_by_name: HashMap::new(),
             desc_ids: HashSet::new(),
         };
@@ -307,8 +307,8 @@ mod tests {
 
         let r1 = r.clone();
         let handler = thread::spawn(move || {
-            let metric_familys = r1.gather();
-            assert_eq!(metric_familys.len(), 1);
+            let metric_families = r1.gather();
+            assert_eq!(metric_families.len(), 1);
         });
 
         assert!(handler.join().is_ok());