Add some lifetimes and fixes

src/capture.rs

@@ -140,10 +140,10 @@ pub fn extract_and_verify_token(events: &[RawEvent]) -> Result<String, String> {
     };
 }
 
-pub async fn process_events(
+pub async fn process_events<'a>(
     sink: Arc<dyn sink::EventSink + Send + Sync>,
-    events: &[RawEvent],
-    context: &ProcessingContext,
+    events: &'a [RawEvent],
+    context: &'a ProcessingContext,
 ) -> Result<(), String> {
     let events: Vec<ProcessedEvent> = match events
         .iter()

src/lib.rs

@@ -5,7 +5,6 @@ pub mod sink;
 pub mod time;
 
 mod capture;
-mod token;
 mod utils;
 mod prometheus;
 mod token;

src/main.rs

@@ -10,24 +10,22 @@ mod sink;
 mod time;
 mod token;
 mod utils;
-
-use crate::time::SystemTime;
-use crate::{router, sink};
+mod prometheus;
 
 #[tokio::main]
 async fn main() {
     let use_print_sink = env::var("PRINT_SINK").is_ok();
     let address = env::var("ADDRESS").unwrap_or(String::from("127.0.0.1:3000"));
 
     let app = if use_print_sink {
-        router::router(SystemTime {}, sink::PrintSink {}, true)
+        router::router(time::SystemTime {}, sink::PrintSink {}, true)
     } else {
         let brokers = env::var("KAFKA_BROKERS").expect("Expected KAFKA_BROKERS");
         let topic = env::var("KAFKA_TOPIC").expect("Expected KAFKA_TOPIC");
 
         let sink = sink::KafkaSink::new(topic, brokers).unwrap();
 
-        router::router(SystemTime {}, sink, true)
+        router::router(time::SystemTime {}, sink, true)
     };
 
     // initialize tracing