Skip to content

Commit fc178de

Browse files
committed
add query canceled metric
1 parent d11ec01 commit fc178de

2 files changed

Lines changed: 9 additions & 1 deletion

File tree

libsql-server/src/connection/libsql.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,9 @@ use tokio::sync::watch;
1515
use tokio::time::{Duration, Instant};
1616

1717
use crate::error::Error;
18-
use crate::metrics::{DESCRIBE_COUNT, PROGRAM_EXEC_COUNT, VACUUM_COUNT, WAL_CHECKPOINT_COUNT};
18+
use crate::metrics::{
19+
DESCRIBE_COUNT, PROGRAM_EXEC_COUNT, QUERY_CANCELED, VACUUM_COUNT, WAL_CHECKPOINT_COUNT,
20+
};
1921
use crate::namespace::broadcasters::BroadcasterHandle;
2022
use crate::namespace::meta_store::MetaStoreHandle;
2123
use crate::namespace::ResolveNamespacePathFn;
@@ -512,6 +514,7 @@ impl<W: Wal> Connection<W> {
512514
Some(move || {
513515
let canceled = canceled.load(Ordering::Relaxed);
514516
if canceled {
517+
QUERY_CANCELED.increment(1);
515518
tracing::trace!("request canceled");
516519
}
517520
canceled

libsql-server/src/metrics.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,3 +153,8 @@ pub static LISTEN_EVENTS_DROPPED: Lazy<Counter> = Lazy::new(|| {
153153
describe_counter!(NAME, "Number of listen events dropped");
154154
register_counter!(NAME)
155155
});
156+
pub static QUERY_CANCELED: Lazy<Counter> = Lazy::new(|| {
157+
const NAME: &str = "libsql_server_query_canceled";
158+
describe_counter!(NAME, "Number of canceled queries");
159+
register_counter!(NAME)
160+
});

0 commit comments

Comments
 (0)