Skip to main content

DatalogWriter

Struct DatalogWriter 

Source
pub struct DatalogWriter { /* private fields */ }
Expand description

Accumulates log entries for a single turn, flushing to disk after each operation.

Implementations§

Source§

impl DatalogWriter

Source

pub fn new(working_dir: &Path, config: &DatalogConfig) -> Self

Source

pub fn new_with_filename_tag( working_dir: &Path, config: &DatalogConfig, filename_tag: &str, ) -> Self

Source

pub fn set_working_dir(&mut self, dir: &Path)

Update the working directory (e.g. after /cd). Absolute / ~/ configured paths are unaffected — only the default and relative cases follow cwd changes.

Source

pub fn resolve_log_dir(base_dir: &Path, configured: Option<&str>) -> PathBuf

Resolve the actual directory to write datalog files into, given the current base_dir and configured_dir. Pure function — used by begin_turn, by runner.rs to decide where log_llm_request writes the JSONL request dump (so both writers stay in sync), and covered by unit tests.

The result is always <root>/<project-slug> so multiple projects don’t collide. <root> is $ATOMCODE_HOME/datalog by default, or whatever the user configured (absolute / ~/… / relative-to-cwd).

Source

pub fn clear(&mut self)

Clear the current turn log state and delete the log file if it exists. Called when user runs /clear command.

Source

pub fn begin_turn( &mut self, user_message: &str, model_name: &str, context_window: usize, )

Start a new turn: create log file, write env info + user message.

Source

pub fn log_llm_call(&mut self)

Log start of a new LLM round-trip (increments the turn counter). Records the duration of the previous LLM turn.

Source

pub fn log_context_stats( &mut self, system_tokens: usize, sent_tokens: usize, dropped_tokens: usize, _working_set_tokens: usize, total_messages: usize, )

Log context statistics for debugging.

Source

pub fn log_cache_hit(&mut self, prompt_tokens: usize, cached_tokens: usize)

Log prompt cache hit info (only when provider reports cached_tokens > 0).

Source

pub fn log_token_usage( &mut self, prompt_tokens: usize, completion_tokens: usize, cached_tokens: usize, )

Log token usage for the current LLM round-trip.

Source

pub fn log_llm_dump( &mut self, messages: &[Message], tool_count: usize, model: &str, context_window: usize, )

Dump full LLM request as JSON into the datalog for debugging. Appends to a single JSONL file (one JSON object per line) colocated with the turn .md file: <turn_timestamp>_requests.jsonl. Each line has the step number so you can correlate with the md.

Source

pub fn log_tool_call(&mut self, name: &str, args: &str)

Log a tool call start (within the current LLM turn).

Source

pub fn log_tool_result(&mut self, output: &str, success: bool)

Log a tool call result.

Source

pub fn log_model_text(&mut self, text: &str)

Log model text output between tool calls (plan, thinking, explanation).

Source

pub fn log_text(&mut self, text: &str)

Log final assistant text output (response/summary).

Source

pub fn log_error(&mut self, error: &str)

Log an error.

Source

pub fn log_warning(&mut self, warning: &str)

Log a non-fatal advisory (e.g. provider truncation detector). Persisting it here makes post-hoc datalog inspection useful even when the live TUI line scrolls past — the user can grep the markdown for **Warning:** after the run.

Source

pub fn end_turn(&mut self, total_tokens: usize, tool_call_count: usize)

End the turn: write duration and final flush.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more