Struct FeedbackAggregator 

pub struct FeedbackAggregator { /* private fields */ }

Accumulates FeedbackEvents across sessions and summarizes them by corpus_id.

Serializable as a flat JSON array of events — same pattern as MetaTrainingRecord::save_list. Append is O(1) amortized; Self::summarize is O(N) per call, which is fine for the scale feedback naturally reaches (hundreds to thousands of events per corpus).

#[serde(transparent)] keeps the derive-based serializer (serde_json::to_string(&agg)) and the hand-rolled Self::save / Self::load path on the same JSON shape — a flat array of events. Without it, the derive would emit {"events": [...]} which load rejects.

Implementations

impl FeedbackAggregator

pub fn new() -> Self

pub fn with_window(max_events: usize) -> Self

Construct with a bounded event window. Once the log reaches max_events, every new record call drops the oldest event so memory stays capped — appropriate for long-running services that only need recent feedback for per-corpus summaries.

Without this cap the event log grows indefinitely; on a 1 event/sec firehose that reaches 100 MB of JSON within a week.

pub fn set_max_events(&mut self, max_events: Option<usize>)

Attach (or drop) the event-count cap after construction.

pub fn len(&self) -> usize

Total number of accumulated events (across all corpus_ids).

pub fn is_empty(&self) -> bool

pub fn record(&mut self, event: FeedbackEvent)

Append one event. When a Self::with_window cap is set and the log is already at capacity, the oldest event is evicted first — a FIFO ring over the underlying Vec.

pub fn events(&self) -> &[FeedbackEvent]

Read-only borrow of the raw event log.

pub fn corpus_ids(&self) -> Vec<String>

Distinct corpus_ids that have any feedback attached.

pub fn summarize(&self, corpus_id: &str) -> Option<FeedbackSummary>

Summarize feedback for a specific corpus. Returns None if the corpus has no events yet.

pub fn summarize_all(&self) -> Vec<FeedbackSummary>

Summarize every corpus that has events. Sorted by corpus_id.

pub fn save(&self, path: impl AsRef<Path>) -> Result<()>

Save this aggregator (event list) to a JSON file. Creates parent directories as needed.

pub fn load(path: impl AsRef<Path>) -> Result<Self>

Load an aggregator from a JSON event-log file. Returns an empty aggregator if the file does not exist.

Accepts both a JSON array (legacy, what save writes for backward compat) and JSON Lines (new format written by FeedbackEvent::append_to_default_store and sibling append paths). Detection is first-character based.

pub fn default_store_path() -> Result<PathBuf>

Default on-disk feedback log: ~/.sphereql/feedback_events.json. Parallel convention to MetaTrainingRecord::default_store_path.

pub fn load_default_store() -> Result<Self>

Load the default on-disk feedback store. Empty aggregator if the store does not exist yet.

Trait Implementations

impl Clone for FeedbackAggregator

fn clone(&self) -> FeedbackAggregator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FeedbackAggregator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FeedbackAggregator

fn default() -> FeedbackAggregator

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FeedbackAggregator

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FeedbackAggregator

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.