Struct AnalyticsStorageAdapter 

pub struct AnalyticsStorageAdapter { /* private fields */ }

Adapts DbPool to the AnalyticsStorage port trait.

Implementations

impl AnalyticsStorageAdapter

pub fn new(pool: DbPool) -> Self

Trait Implementations

impl AnalyticsStorage for AnalyticsStorageAdapter

fn store_follower_snapshot<'life0, 'async_trait>( &'life0 self, followers: i64, following: i64, tweets: i64, ) -> Pin<Box<dyn Future<Output = Result<(), AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store a daily follower snapshot.

fn get_yesterday_followers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<i64>, AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get yesterday’s follower count (for drop detection).

fn get_replies_needing_measurement<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get reply IDs posted approximately 24h ago that need performance measurement.

fn get_tweets_needing_measurement<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get tweet IDs posted approximately 24h ago that need performance measurement.

fn store_reply_performance<'life0, 'life1, 'async_trait>( &'life0 self, reply_id: &'life1 str, likes: i64, replies: i64, impressions: i64, score: f64, ) -> Pin<Box<dyn Future<Output = Result<(), AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store reply performance metrics.

fn store_tweet_performance<'life0, 'life1, 'async_trait>( &'life0 self, tweet_id: &'life1 str, likes: i64, retweets: i64, replies: i64, impressions: i64, score: f64, ) -> Pin<Box<dyn Future<Output = Result<(), AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store tweet performance metrics.

fn update_content_score<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic: &'life1 str, format: &'life2 str, score: f64, ) -> Pin<Box<dyn Future<Output = Result<(), AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update the content score running average for a topic.

fn log_action<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, action_type: &'life1 str, status: &'life2 str, message: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Log an action.

fn run_aggregations<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Run background aggregation jobs (best-times heatmap, reach snapshots).

fn run_forge_sync_if_enabled<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<ForgeSyncResult>, AnalyticsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Run Forge sync if the active content source has analytics sync enabled.