Function get_log_sender

chirpstack/src/stream/backend_interfaces.rs:10–29

()

use chirpstack_api::stream;

pub async fn get_log_sender() -> Option<Sender<stream::BackendInterfacesRequest>> {
    let conf = config::get();
    if conf.monitoring.backend_interfaces_log_max_history == 0 {
        return None;
    }

    let (tx, mut rx) = mpsc::channel(100);

    tokio::spawn(async move {
        while let Some(pl) = rx.recv().await {
            tokio::spawn(async move {
                if let Err(e) = log_request(pl).await {
                    error!(error = %e, "Log request error");
                }
            });
        }
    });

    Some(tx)
}

pub async fn log_request(pl: stream::BackendInterfacesRequest) -> Result<()> {
    let conf = config::get();