Struct NoaaClient 

pub struct NoaaClient { /* private fields */ }

Client for NOAA climate data

Implementations

impl NoaaClient

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

Create a new NOAA client

Arguments

• api_token - NOAA API token (get from https://www.ncdc.noaa.gov/cdo-web/token)

pub async fn fetch_climate_data( &self, station_id: &str, start_date: &str, end_date: &str, ) -> Result<Vec<DataRecord>>

Fetch climate data for a station

Arguments

• station_id - GHCND station ID (e.g., “GHCND:USW00094728” for NYC)
• start_date - Start date (YYYY-MM-DD)
• end_date - End date (YYYY-MM-DD)

Trait Implementations

impl DataSource for NoaaClient

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