1 files changed, 103 insertions, 0 deletions
diff --git a/src/stats/aggregated.rs b/src/stats/aggregated.rs
index e69de29..afff109 100644
--- a/src/stats/aggregated.rs
+++ b/src/stats/aggregated.rs
@@ -0,0 +1,103 @@
+// Copyright 2017-2019 int08h LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+use hashbrown::HashMap;
+use hashbrown::hash_map::Iter;
+
+use std::net::IpAddr;
+
+use crate::stats::ClientStatEntry;
+use crate::stats::ServerStats;
+
+///
+/// Implementation of `ServerStats` that provides high-level aggregated client statistics. No
+/// per-client statistic are maintained and runtime memory use is constant.
+///
+#[allow(dead_code)]
+pub struct AggregatedStats {
+    valid_requests: u64,
+    invalid_requests: u64,
+    health_checks: u64,
+    responses_sent: u64,
+    bytes_sent: usize,
+    empty_map: HashMap<IpAddr, ClientStatEntry>,
+}
+
+impl AggregatedStats {
+
+    #[allow(dead_code)]
+    pub fn new() -> Self {
+        AggregatedStats {
+            valid_requests: 0,
+            invalid_requests: 0,
+            health_checks: 0,
+            responses_sent: 0,
+            bytes_sent: 0,
+            empty_map: HashMap::new()
+        }
+    }
+}
+
+impl ServerStats for AggregatedStats {
+    fn add_valid_request(&mut self, _: &IpAddr) {
+        self.valid_requests += 1
+    }
+
+    fn add_invalid_request(&mut self, _: &IpAddr) {
+        self.invalid_requests += 1
+    }
+
+    fn add_health_check(&mut self, _: &IpAddr) {
+        self.health_checks += 1
+    }
+
+    fn add_response(&mut self, _: &IpAddr, bytes_sent: usize) {
+        self.bytes_sent += bytes_sent;
+        self.responses_sent += 1;
+    }
+
+    fn total_valid_requests(&self) -> u64 {
+        self.valid_requests
+    }
+
+    fn total_invalid_requests(&self) -> u64 {
+        self.invalid_requests
+    }
+
+    fn total_health_checks(&self) -> u64 {
+        self.health_checks
+    }
+
+    fn total_responses_sent(&self) -> u64 {
+        self.responses_sent
+    }
+
+    fn total_bytes_sent(&self) -> usize {
+        self.bytes_sent
+    }
+
+    fn total_unique_clients(&self) -> u64 {
+        0
+    }
+
+    fn get_client_stats(&self, _addr: &IpAddr) -> Option<&ClientStatEntry> {
+        None
+    }
+
+    fn iter(&self) -> Iter<IpAddr, ClientStatEntry> {
+        self.empty_map.iter()
+    }
+
+    fn clear(&mut self) {}
+}