Set the origin peer ID (called once during EventPlane startup).
(peer_id: u64)
| 52 | |
| 53 | /// Set the origin peer ID (called once during EventPlane startup). |
| 54 | pub fn set_origin_peer_id(peer_id: u64) { |
| 55 | ORIGIN_PEER_ID.store(peer_id, Ordering::Relaxed); |
| 56 | } |
| 57 | |
| 58 | /// Shared packager state (owned by the Event Plane, called from consumer loop). |
| 59 | pub struct DeltaPackager { |