#tracing-layer #tracing #webhook #layer #filter #async

tracing-layer-core

Send filtered tracing events to a webhook endpoint

3 unstable releases

0.2.1 Apr 21, 2024
0.2.0 Apr 15, 2024
0.1.0 Apr 15, 2024

#361 in Debugging

Download history 264/week @ 2024-04-14 168/week @ 2024-04-21

432 downloads per month
Used in 2 crates

Apache-2.0

31KB
418 lines

tracing-layer-slack-discord

This repository contains Layer implementations for sending tracing events to Slack and Discord.

tracing-layer-slack tracing-layer-slack on crates.io Docs

tracing-layer-discord tracing-layer-discord on crates.io Docs

Synopsis

DiscordLayer and SlackLayer send POST requests via tokio and reqwest to a Discord Webhook URL and Slack Webhook URL for each new tracing event, depending on the user-supplied event filtering rules. The format of the embedded message is statically defined.

This layer also looks for an optional JsonStorageLayer extension on the parent span of each event. This extension may contain additional contextual information for the parent span of an event, which is included into the Discord message.

Features

  • Send trace logs to Slack and Discord channels.
  • Configurable to suit your needs.
  • Easy to integrate with existing Rust applications.

Usage

Add the following to your Cargo.toml:

[dependencies]
tracing-layer-slack = "0"
tracing-layer-discord = "0"

Then, in your application:

use regex::Regex;
use tracing::{info, instrument, warn};
use tracing_subscriber::{layer::SubscriberExt, Registry};

use tracing_layer_slack::{EventFilters, SlackLayer};
use tracing_layer_discord::{EventFilters, DiscordLayer};

#[instrument]
pub async fn network_io(id: u64) {
    warn!(user_id = id, "had to retry the request once");
}

#[tokio::main]
async fn main() {
    // Only show events from where this example code is the target.
    let target_to_filter: EventFilters = Regex::new("simple").unwrap().into();

    let app_name = "test-app".to_string();
    let (slack_layer, slack_worker) = SlackLayer::builder(app_name.clone(), target_to_filter.clone()).build();
    let (discord_layer, discord_worker) = DiscordLayer::builder(app_name, target_to_filter).build();
    let subscriber = Registry::default().with(slack_layer);
    tracing::subscriber::set_global_default(subscriber).unwrap();

    network_io(123).await;
    
    slack_worker.shutdown().await;
    discord_worker.shutdown().await;
}

License

This project is licensed under the MIT License - see the LICENSE file for details.

Dependencies

~12–33MB
~487K SLoC