Struct FeedbackCollector 

pub struct FeedbackCollector { /* private fields */ }

Collector for implicit feedback signals.

Thread-safe and designed for concurrent access from multiple queries.

Implementations

impl FeedbackCollector

pub fn new() -> Self

Create a new feedback collector with default config.

pub fn with_config(config: FeedbackConfig) -> Self

Create with custom configuration.

pub async fn start_session(&self) -> SessionId

Start a new session.

pub async fn get_or_create_session( &self, session_id: Option<SessionId>, ) -> SessionId

Get or create a session (for stateless APIs).

pub async fn record_query( &self, session_id: SessionId, query_text: &str, result_ids: Vec<Uuid>, query_embedding: Option<Vec<f32>>, ) -> QueryId

Record a query and its results.

pub async fn record_view( &self, session_id: SessionId, entry_id: Uuid, position: usize, )

Record that a user viewed a result.

pub async fn record_select( &self, session_id: SessionId, entry_id: Uuid, position: usize, )

Record that a user selected/used a result.

pub async fn record_dismiss( &self, session_id: SessionId, entry_id: Uuid, position: usize, )

Record that a user dismissed a result.

pub async fn record_dwell( &self, session_id: SessionId, entry_id: Uuid, duration_ms: u64, )

Record dwell time on a result.

pub async fn end_session(&self, session_id: SessionId)

End a session explicitly.

pub async fn cleanup_expired_sessions(&self)

Clean up expired sessions.

pub async fn drain_signals(&self) -> Vec<FeedbackSignal>

Drain all buffered signals for processing.

pub async fn pending_signals(&self) -> usize

Get number of buffered signals.

pub fn total_signals(&self) -> u64

Get total signals collected.

pub fn total_sessions(&self) -> u64

Get total sessions created.

pub async fn active_sessions(&self) -> usize

Get number of active sessions.

Trait Implementations

impl Default for FeedbackCollector

fn default() -> Self

Returns the “default value” for a type.