Struct PvPool 

pub struct PvPool { /* private fields */ }

A pool of PV inverters in the microgrid.

Created with Microgrid::pv_pool, passing either an explicit set of PV inverter component IDs or None to cover every PV inverter in the microgrid. It exposes:

• power — a Formula for the pool’s aggregate active power;
• power_bounds — a stream of the pool’s aggregated active-power bounds;
• telemetry_snapshots — a stream of PvPoolSnapshots partitioning the inverters into healthy and unhealthy sets.

The bounds and snapshot streams share a telemetry tracker that is started on first use and reused while it still has live receivers.

Example

use chrono::TimeDelta;
use frequenz_microgrid::{LogicalMeterConfig, Microgrid};

let microgrid = Microgrid::try_new(
    "grpc://localhost:50051",
    LogicalMeterConfig::new(TimeDelta::try_seconds(1).unwrap()),
)
.await?;

// A pool over every PV inverter in the microgrid.
let mut pv_pool = microgrid.pv_pool(None)?;

// Subscribe to the pool's aggregated active-power bounds.
let mut bounds_rx = pv_pool.power_bounds();
while let Ok(bounds) = bounds_rx.recv().await {
    println!("PV pool active-power bounds: {bounds:?}");
}

Implementations

impl PvPool

pub fn power(&mut self) -> Result<Formula<Power>, Error>

Returns a formula for the active power of the PV pool.

pub fn power_bounds(&mut self) -> Receiver<Vec<Bounds<Power>>>

Returns a receiver for the aggregated active-power bounds of the pool, updated on each snapshot.

Reuses the running bounds tracker if one exists and still has active receivers; otherwise starts a new one (which also starts or reuses the underlying telemetry tracker).

pub fn telemetry_snapshots(&mut self) -> Receiver<PvPoolSnapshot>

Returns a receiver for a stream of PvPoolSnapshot values, each reflecting the latest inverter telemetry partitioned into healthy and unhealthy sets.

Reuses the running tracker if one exists and still has active receivers (including any held by a bounds tracker); otherwise starts a new one.