(&self, pl: &integration_pb::LogEvent)
| 406 | } |
| 407 | |
| 408 | async fn log_event(&self, pl: &integration_pb::LogEvent) -> Result<()> { |
| 409 | LOG_EVENTS.write().await.push(pl.clone()); |
| 410 | Ok(()) |
| 411 | } |
| 412 | |
| 413 | async fn status_event(&self, pl: &integration_pb::StatusEvent) -> Result<()> { |
| 414 | STATUS_EVENTS.write().await.push(pl.clone()); |