Merge pull request #25 from amirjang/master

Issue in sampled_count function
markstory · Mar 31, 2021 · 6b15dd2 · 6b15dd2
2 parents 4b9e303 + 810e5e2
commit 6b15dd2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/client.rs b/src/client.rs
@@ -131,10 +131,10 @@ impl Client {
     /// client.sampled_count("metric.completed", 4, 0.5);
     /// ```
     pub fn sampled_count(&self, metric: &str, value: f64, rate: f64) {
-        if rand::random::<f64>() < rate {
+        if rand::random::<f64>() >= rate {
             return;
         }
-        let data = self.prepare(format!("{}:{}|c", metric, value));
+        let data = self.prepare(format!("{}:{}|c|@{}", metric, value, rate));
         self.send(data);
     }
 
@@ -310,10 +310,10 @@ impl Pipeline {
     /// pipe.sampled_count("metric.completed", 4.0, 0.5);
     /// ```
     pub fn sampled_count(&mut self, metric: &str, value: f64, rate: f64) {
-        if rand::random::<f64>() < rate {
+        if rand::random::<f64>() >= rate {
             return;
         }
-        let data = format!("{}:{}|c", metric, value);
+        let data = format!("{}:{}|c|@{}", metric, value, rate);
         self.stats.push_back(data);
     }