Struct AgentLogger 

pub struct AgentLogger { /* private fields */ }

The structured logger. One instance == one run == one JSONL file.

Thread-safe: the underlying file handle is guarded by a Mutex and the sequence counter is atomic.

Implementations

impl AgentLogger

pub fn new( program: &str, command: Option<&str>, log_dir: impl AsRef<Path>, rid: Option<&str>, ) -> Result<Self>

Create a new logger (and its log file).

• program – program name (filename component, sanitised).
• command – sub-command; None → pid{PID}.
• log_dir – directory for log files (./logs is typical).
• rid – run id override; None → random 8 hex chars.

Examples found in repository

examples/rust_emit.rs (line 5)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn new_compact( program: &str, command: Option<&str>, log_dir: impl AsRef<Path>, rid: Option<&str>, compact: bool, ) -> Result<Self>

Like [new], but enables compact-key mode (contract §4).

pub fn file_path(&self) -> &Path

Absolute path of the active log file.

Examples found in repository

examples/rust_emit.rs (line 13)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn rid(&self) -> &str

pub fn program(&self) -> &str

pub fn command(&self) -> &str

pub fn save_traceback( &self, exc_type: &str, exc_msg: &str, traceback: &str, ) -> Result<String>

Persist a traceback to the .tracebacks sidecar; returns the generated tid.

pub fn save_traceback_text( &self, tid: &str, exc_type: &str, exc_msg: &str, traceback: &str, ) -> Result<()>

pub fn info(&self, msg: &str, module: Option<&str>) -> Result<()>

logger.info(msg, module, dur?, error_code?, tid?, ctx?)

pub fn info_full( &self, msg: &str, module: Option<&str>, dur: Option<u64>, error_code: Option<&str>, tid: Option<&str>, ctx: Option<Value>, ) -> Result<()>

Examples found in repository

examples/rust_emit.rs (line 6)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn warn(&self, msg: &str, module: Option<&str>) -> Result<()>

pub fn warn_full( &self, msg: &str, module: Option<&str>, dur: Option<u64>, error_code: Option<&str>, tid: Option<&str>, ctx: Option<Value>, ) -> Result<()>

pub fn error( &self, msg: &str, module: Option<&str>, error_code: ErrorCode, tid: Option<&str>, ) -> Result<()>

Examples found in repository

examples/rust_emit.rs (line 8)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn error_full( &self, msg: &str, module: Option<&str>, error_code: &str, tid: Option<&str>, dur: Option<u64>, ctx: Option<Value>, ) -> Result<()>

pub fn tool_call( &self, tool: &str, cmd: &str, exit: i64, dur: u64, error_code: Option<&str>, tid: Option<&str>, stdout: Option<&str>, stderr: Option<&str>, ctx: Option<Value>, ) -> Result<()>

tool_call(tool, cmd, exit, dur, error_code?, tid?, stdout?, stderr?, ctx?). Like Python, requires error_code semantics for failures are the caller’s responsibility (this SDK accepts it optionally).

Examples found in repository

examples/rust_emit.rs (line 7)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn file_op( &self, op: &str, path: &str, ok: bool, size: Option<u64>, error_code: Option<&str>, tid: Option<&str>, dur: Option<u64>, ctx: Option<Value>, ) -> Result<()>

Examples found in repository

examples/rust_emit.rs (line 9)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn decision( &self, choice: &str, alts: Option<&[&str]>, reason: Option<&str>, confidence: Option<f64>, module: Option<&str>, ctx: Option<Value>, ) -> Result<()>

Examples found in repository

examples/rust_emit.rs (line 10)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn code_gen( &self, lang: &str, path: &str, lines: Option<u64>, funcs: Option<&[&str]>, imports: Option<&[&str]>, module: Option<&str>, ctx: Option<Value>, ) -> Result<()>

Examples found in repository

examples/rust_emit.rs (line 11)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}

pub fn context_switch( &self, to_task: &str, from_task: Option<&str>, reason: Option<&str>, module: Option<&str>, ctx: Option<Value>, ) -> Result<()>

Examples found in repository

examples/rust_emit.rs (line 12)

fn main() {
    let dir = std::env::args().nth(1).unwrap_or_else(|| "/tmp/xlang_rust".into());
    let lg = AgentLogger::new("rust_probe", Some("demo"), &dir, Some("cafebabe")).unwrap();
    lg.info_full("Processing started", Some("parser"), Some(12), None, None, Some(json!({"file":"data.json","size":1024}))).ok();
    lg.tool_call("bash", "npm install", 0, 1234, None, None, Some("added 50 pkgs"), None, None).ok();
    lg.error("Build failed", Some("build"), ErrorCode::ExecNonZero, Some("tb_abcd1234")).ok();
    lg.file_op("write", "/p/f.rs", true, Some(2048), None, None, Some(5), None).ok();
    lg.decision("use_redis", Some(&["redis","memcached"]), Some("perf"), Some(0.85), Some("arch"), None).ok();
    lg.code_gen("rust", "src/main.rs", Some(50), Some(&["main","helper"]), None, None, None).ok();
    lg.context_switch("test", Some("build"), Some("done"), None, None).ok();
    println!("{}", lg.file_path().display());
}