Struct RedditClient 

pub struct RedditClient { /* private fields */ }

Client for Reddit JSON endpoints

Implementations

impl RedditClient

pub fn new() -> Result<Self>

Create a new Reddit client

No authentication required for .json endpoints. Be respectful with rate limiting.

pub async fn get_subreddit_posts( &self, subreddit: &str, sort: &str, limit: usize, ) -> Result<Vec<DataRecord>>

Get subreddit posts

Arguments

• subreddit - Subreddit name (without r/)
• sort - Sort method: “hot”, “new”, “top”, “rising”
• limit - Maximum number of posts (capped at 100)

pub async fn get_post_comments(&self, post_id: &str) -> Result<Vec<DataRecord>>

Get post comments

Arguments

• post_id - Reddit post ID (e.g., “abc123”)

pub async fn search( &self, query: &str, subreddit: Option<&str>, limit: usize, ) -> Result<Vec<DataRecord>>

Search Reddit

Arguments

• query - Search query
• subreddit - Optional subreddit to search within
• limit - Maximum number of results

Trait Implementations

impl DataSource for RedditClient

fn source_id(&self) -> &str

Source identifier

fn fetch_batch<'life0, 'async_trait>( &'life0 self, cursor: Option<String>, batch_size: usize, ) -> Pin<Box<dyn Future<Output = Result<(Vec<DataRecord>, Option<String>)>> + Send + 'async_trait>>

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

Fetch a batch of records starting from cursor

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

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

Get total record count (if known)

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

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

Check if source is available