Create a new [`Extension`] with a service that receives Lambda logs.
(self, lp: N)
| 138 | |
| 139 | /// Create a new [`Extension`] with a service that receives Lambda logs. |
| 140 | pub fn with_logs_processor<N, NS>(self, lp: N) -> Extension<'a, E, N, T, TL> |
| 141 | where |
| 142 | N: Service<()>, |
| 143 | N::Future: Future<Output = Result<NS, N::Error>>, |
| 144 | N::Error: Into<Error> + fmt::Display, |
| 145 | { |
| 146 | Extension { |
| 147 | logs_processor: Some(lp), |
| 148 | events_processor: self.events_processor, |
| 149 | extension_name: self.extension_name, |
| 150 | events: self.events, |
| 151 | log_types: self.log_types, |
| 152 | log_buffering: self.log_buffering, |
| 153 | log_port_number: self.log_port_number, |
| 154 | telemetry_types: self.telemetry_types, |
| 155 | telemetry_buffering: self.telemetry_buffering, |
| 156 | telemetry_processor: self.telemetry_processor, |
| 157 | telemetry_port_number: self.telemetry_port_number, |
| 158 | _telemetry_record_type: self._telemetry_record_type, |
| 159 | } |
| 160 | } |
| 161 | |
| 162 | /// Create a new [`Extension`] with a list of logs types to subscribe. |
| 163 | /// The only accepted log types are `function`, `platform`, and `extension`. |