Method with_telemetry_processor

lambda-extension/src/extension.rs:192–212

Create a new [`Extension`] with a service that receives Lambda telemetry data. By default, telemetry log records are deserialized as `String`, but it's possible to configure Lambda functions to emit logs in JSON format. For more information, refer to [`Self::with_telemetry_record_type`].

(self, lp: N)

    /// it's possible to configure Lambda functions to emit logs in JSON format.
    /// For more information, refer to [`Self::with_telemetry_record_type`].
    pub fn with_telemetry_processor<N, NS>(self, lp: N) -> Extension<'a, E, L, N, TL>
    where
        N: Service<()>,
        N::Future: Future<Output = Result<NS, N::Error>>,
        N::Error: Into<Error> + fmt::Display,
    {
        Extension {
            telemetry_processor: Some(lp),
            events_processor: self.events_processor,
            extension_name: self.extension_name,
            events: self.events,
            log_types: self.log_types,
            log_buffering: self.log_buffering,
            logs_processor: self.logs_processor,
            log_port_number: self.log_port_number,
            telemetry_types: self.telemetry_types,
            telemetry_buffering: self.telemetry_buffering,
            telemetry_port_number: self.telemetry_port_number,
            _telemetry_record_type: self._telemetry_record_type,
        }
    }

    /// Create a new [`Extension`] with a list of telemetry types to subscribe.
    /// The only accepted telemetry types are `function`, `platform`, and `extension`.