Struct RecommendationEngine 

pub struct RecommendationEngine { /* private fields */ }

Main recommendation engine coordinating all recommendation capabilities

Implementations

impl RecommendationEngine

pub fn new() -> Self

Create a new recommendation engine with no rate limiting.

pub fn with_rate_limiter(config: RateLimitConfig, now: i64) -> Self

Create a new recommendation engine with rate limiting enabled.

config controls per-user and global token-bucket parameters. now is the initial Unix timestamp (seconds) used to seed the buckets.

pub fn set_rate_limiter(&mut self, config: RateLimitConfig, now: i64)

Enable (or replace) the rate limiter on an existing engine.

pub fn disable_rate_limiter(&mut self)

Disable rate limiting on this engine.

pub fn has_rate_limiter(&self) -> bool

Returns true if rate limiting is currently enabled.

pub fn user_available_tokens(&self, user_id: &str) -> Option<f64>

Query how many tokens remain for a user without consuming any.

Returns None if rate limiting is disabled or if the user has no bucket yet.

pub fn global_available_tokens(&self) -> Option<f64>

Query how many global tokens remain without consuming any.

Returns None if rate limiting is disabled.

pub fn recommend( &mut self, request: &RecommendationRequest, ) -> RecommendResult<RecommendationResults>

Get recommendations for a user

For the Hybrid strategy, all sub-strategies are evaluated in parallel via rayon. The resulting candidate lists are merged and deduplicated by content ID, taking the maximum score for any item that appeared in multiple strategy outputs.

If a rate limiter is configured, the request is checked against both the per-user and global token buckets. When the limit is exceeded a RecommendError::RateLimited error is returned immediately.

Errors

Returns an error if recommendation generation fails or the caller is rate-limited.

pub fn record_view( &mut self, user_id: Uuid, content_id: Uuid, watch_time_ms: i64, completed: bool, ) -> RecommendResult<()>

Record a user view event

Errors

Returns an error if recording fails

pub fn record_rating( &mut self, user_id: Uuid, content_id: Uuid, rating: f32, ) -> RecommendResult<()>

Record an explicit rating

Errors

Returns an error if recording fails

pub fn update_trending(&mut self) -> RecommendResult<()>

Update trending scores

Errors

Returns an error if update fails

pub fn get_user_profile(&self, user_id: Uuid) -> RecommendResult<UserProfile>

Get user profile

Errors

Returns an error if retrieval fails

pub fn get_similar_users( &self, user_id: Uuid, limit: usize, ) -> RecommendResult<Vec<Uuid>>

Get similar users

Errors

Returns an error if retrieval fails

Trait Implementations

impl Default for RecommendationEngine

fn default() -> Self

Returns the “default value” for a type.