sc-observability 1.0.0

Standalone facade crate for observability operations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

#![expect(
    clippy::missing_errors_doc,
    reason = "reader error behavior is documented at the public facade level, and repeating it here would add low-signal boilerplate"
)]
#![expect(
    clippy::must_use_candidate,
    reason = "lightweight constructors are intentionally kept free of repetitive must_use decoration"
)]

use std::path::PathBuf;
use std::sync::Arc;

use sc_observability_types::{LogQuery, LogSnapshot, QueryError, QueryHealthState};

use crate::follow::LogFollowSession;
use crate::health::QueryHealthTracker;
use crate::query;

/// Independent JSONL reader for historical query and follow operations.
#[derive(Debug, Clone)]
pub struct JsonlLogReader {
    active_log_path: PathBuf,
}

impl JsonlLogReader {
    /// Creates a reader over the active JSONL log path and its rotation set.
    pub fn new(active_log_path: PathBuf) -> Self {
        Self { active_log_path }
    }

    /// Queries the current active JSONL log and visible rotation set.
    pub fn query(&self, query: &LogQuery) -> Result<LogSnapshot, QueryError> {
        query::query_snapshot(&self.active_log_path, query)
    }

    /// Starts a tail-style follow session beginning at the end of the current visible log set.
    pub fn follow(&self, query: LogQuery) -> Result<LogFollowSession, QueryError> {
        LogFollowSession::with_health(
            self.active_log_path.clone(),
            query,
            Arc::new(QueryHealthTracker::new(QueryHealthState::Healthy)),
            None,
        )
    }
}