Struct my_iot::services::buienradar::Buienradar

pub struct Buienradar {
    service_id: String,
    station_id: u32,
    client: Client,
}

Fields

service_id: String

station_id: u32

client: Client

Methods

impl Buienradar

pub fn new(service_id: &str, settings: &Settings) -> Result<Buienradar, Error>

fn fetch(&self) -> Result<BuienradarStationMeasurement, Error>

Fetch measurement for the configured station.

fn send_readings(
    &self,
    measurement: BuienradarStationMeasurement,
    tx: &Sender<Reading>
) -> Result<(), Error>

Sends out readings based on Buienradar station measurement.

Trait Implementations

impl Service for Buienradar

fn spawn(
    self: Box<Self>,
    _db: Arc<Mutex<Db>>,
    tx: Sender<Reading>,
    _rx: Receiver<Reading>
) -> Result<(), Error>

Spawn service threads.

fn send(
    &self,
    tx: &Sender<Reading>,
    readings: Vec<Reading>
) -> Result<(), Error>

Convenience function to send multiple readings at once.