use std::sync::{Arc, RwLock};
use std::collections::HashMap;
use std::collections::hash_map::Entry;
use proto;
use metrics::Collector;
use errors::{Result, Error};
struct RegistryCore {
pub colloctors_by_id: HashMap<u64, Box<Collector>>,
pub dim_hashes_by_name: HashMap<String, u64>,
}
impl RegistryCore {
fn register(&mut self, c: Box<Collector>) -> Result<()> {
let id = {
let desc = c.desc();
if let Some(hash) = self.dim_hashes_by_name.get(&desc.fq_name) {
if *hash != desc.dim_hash {
return Err(Error::Msg(format!("a previously registered descriptor with the \
same fully-qualified name as {:?} has \
different label names or a different help \
string",
desc)));
}
}
if self.colloctors_by_id.contains_key(&desc.id) {
return Err(Error::AlreadyReg);
}
self.dim_hashes_by_name.insert(desc.fq_name.clone(), desc.dim_hash);
desc.id
};
self.colloctors_by_id.insert(id, c);
Ok(())
}
fn unregister(&mut self, c: Box<Collector>) -> Result<()> {
let desc = c.desc();
if self.colloctors_by_id.remove(&desc.id).is_none() {
return Err(Error::Msg(format!("collector {:?} is not registered", desc)));
}
Ok(())
}
fn gather(&self) -> Vec<proto::MetricFamily> {
let mut mf_by_name = HashMap::new();
for c in self.colloctors_by_id.values() {
let mut mf = c.collect();
let name = mf.get_name().to_owned();
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();
for metric in mf.take_metric().into_iter() {
existent_metrics.push(metric);
}
}
}
}
mf_by_name.into_iter().map(|(_, m)| m).collect()
}
}
#[derive(Clone)]
pub struct Registry {
r: Arc<RwLock<RegistryCore>>,
}
impl Default for Registry {
fn default() -> Registry {
let r = RegistryCore {
colloctors_by_id: HashMap::new(),
dim_hashes_by_name: HashMap::new(),
};
Registry { r: Arc::new(RwLock::new(r)) }
}
}
impl Registry {
pub fn new() -> Registry {
Registry::default()
}
pub fn register(&self, c: Box<Collector>) -> Result<()> {
self.r.write().unwrap().register(c)
}
pub fn unregister(&self, c: Box<Collector>) -> Result<()> {
self.r.write().unwrap().unregister(c)
}
pub fn gather(&self) -> Vec<proto::MetricFamily> {
self.r.read().unwrap().gather()
}
}
#[cfg(test)]
mod tests {
use std::thread;
use counter::{Counter, CounterVec};
use metrics::Opts;
use super::*;
#[test]
fn test_registry() {
let r = Registry::new();
let counter = Counter::new("test", "test help").unwrap();
r.register(Box::new(counter.clone())).unwrap();
counter.inc();
let r1 = r.clone();
let handler = thread::spawn(move || {
let metric_familys = r1.gather();
assert_eq!(metric_familys.len(), 1);
});
assert!(handler.join().is_ok());
assert!(r.register(Box::new(counter.clone())).is_err());
assert!(r.unregister(Box::new(counter.clone())).is_ok());
assert!(r.unregister(Box::new(counter.clone())).is_err());
let counter_vec = CounterVec::new(Opts::new("test_vec", "test vec help"), &["a", "b"])
.unwrap();
r.register(Box::new(counter_vec.clone())).unwrap();
counter_vec.with_label_values(&["1", "2"]).inc();
}
}