Struct GuardianClient 

pub struct GuardianClient { /* private fields */ }

Client for The Guardian API

Implementations

impl GuardianClient

pub fn new(api_key: Option<String>) -> Result<Self>

Create a new Guardian client

Arguments

• api_key - Guardian API key (get from https://open-platform.theguardian.com/)

Free tier: 12 calls/sec, 5000/day

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

Search articles

Arguments

• query - Search query
• limit - Maximum number of results (capped at 200)

pub async fn get_article(&self, id: &str) -> Result<DataRecord>

Get article by ID

Arguments

• id - Article ID (e.g., “world/2024/jan/01/article-slug”)

pub async fn get_sections(&self) -> Result<Vec<DataRecord>>

Get all sections

pub async fn search_by_tag( &self, tag: &str, limit: usize, ) -> Result<Vec<DataRecord>>

Search by tag

Arguments

• tag - Tag ID
• limit - Maximum number of results

Trait Implementations

impl DataSource for GuardianClient

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