Struct OpenAlexClient 

pub struct OpenAlexClient { /* private fields */ }

Client for OpenAlex scholarly database

Implementations

impl OpenAlexClient

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

Create a new OpenAlex client

Arguments

• user_email - Email for polite API usage (optional but recommended)

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

Search scholarly works

Arguments

• query - Search query string
• limit - Maximum number of results (max 200 per request)

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

Get work by OpenAlex ID

Arguments

• id - OpenAlex work ID (e.g., “W2741809807”)

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

Search authors

Arguments

• query - Author name or affiliation
• limit - Maximum number of results

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

Get citing works for a given work ID

Arguments

• work_id - OpenAlex work ID

Trait Implementations

impl DataSource for OpenAlexClient

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