5b5ba29 feat: log event queue length at log level "trace" — radicle-ci-broker

Radicle CI broker

feat: log event queue length at log level "trace"

Lars Wirzenius committed 1 year ago

commit 5b5ba29e9df4755c9ea9af617c3eea453ad5316d
parent c8d6c0f53f245459d082103dcf14d8d9b85d34a4

2 files changed +8 -2

modified src/logger.rs

@@ -5,7 +5,7 @@ use std::sync::Once;

 use std::{path::Path, sync::Mutex, time::Duration};
 use radicle::{git::raw::Oid, identity::RepoId, node::Event};
 use slog::{debug, error, info, o, warn, Drain};
 use slog::{debug, error, info, o, trace, warn, Drain};
 use slog_scope::GlobalLoggerGuard;
 use crate::{

@@ -160,6 +160,12 @@ pub fn queueproc_channel_disconnect() {

     );
 }
 pub fn queueproc_queue_length(len: usize) {
     trace!(
         slog_scope::logger(),
         "event queue length"; "length" => len);
 }
 pub fn queueproc_picked_event(id: &QueueId, event: &QueuedCiEvent) {
     info!(
         slog_scope::logger(),

modified src/queueproc.rs

@@ -100,7 +100,7 @@ impl QueueProcessor {

     fn pick_event(&self) -> Result<Option<QueuedCiEvent>, QueueError> {
         let ids = self.db.queued_ci_events().map_err(QueueError::db)?;
         logger::debug2(format!("queue in db has {} events", ids.len()));
         logger::queueproc_queue_length(ids.len());
         let mut queue = vec![];
         for id in ids.iter() {