(conf: Configuration)
| 303 | } |
| 304 | |
| 305 | pub async fn start(conf: Configuration) -> Result<()> { |
| 306 | let int = Integration::new(&conf)?; |
| 307 | int.start().await |
| 308 | } |
| 309 | |
| 310 | async fn uplink_event(pl: integration_pb::UplinkEvent) { |
| 311 | let integration = INTEGRATION.read().await; |