()
| 28 | |
| 29 | #[tokio::main] |
| 30 | async fn main() -> Result<(), Error> { |
| 31 | // required to enable CloudWatch error logging by the runtime |
| 32 | tracing::init_default_subscriber(); |
| 33 | |
| 34 | let func = service_fn(my_extension); |
| 35 | let logs_processor = SharedService::new(service_fn(my_log_processor)); |
| 36 | |
| 37 | Extension::new() |
| 38 | .with_events_processor(func) |
| 39 | .with_logs_processor(logs_processor) |
| 40 | .run() |
| 41 | .await |
| 42 | } |
nothing calls this directly
no test coverage detected