tornadocontrib/ web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

dedup keys

This commit is contained in:
Bryan Stitt 2023-01-25 00:27:07 -08:00
parent 7e5418a8e7
commit 0c387af589
2 changed files with 24 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
web3_proxy/src/bin/web3_proxy_cli/main.rs
View File

@ -23,6 +23,8 @@ use log::{error, info, warn};
use pagerduty_rs::eventsv2sync::EventsV2 as PagerdutySyncEventsV2;
use pagerduty_rs::types::{AlertTrigger, AlertTriggerPayload};
use pagerduty_rs::{eventsv2async::EventsV2 as PagerdutyAsyncEventsV2, types::Event};
use std::collections::hash_map::DefaultHasher;
use std::hash::{Hash, Hasher};
use std::{
fs, panic,
path::Path,
@ -257,9 +259,14 @@ fn main() -> anyhow::Result<()> {
} else {
error!("sending panic to pagerduty: {}", panic_msg);
let mut s = DefaultHasher::new();
panic_msg.hash(&mut s);
panic_msg.hash(&mut s);
let dedup_key = s.finish().to_string();
let payload = AlertTriggerPayload {
severity: pagerduty_rs::types::Severity::Error,
summary: panic_msg.clone(),
summary: panic_msg,
source: hostname,
timestamp: None,
component: None,
@ -270,7 +277,7 @@ fn main() -> anyhow::Result<()> {
let event = Event::AlertTrigger(AlertTrigger {
payload,
dedup_key: None,
dedup_key: Some(dedup_key),
images: None,
links: None,
client: Some(client.clone()),

16
web3_proxy/src/pagerduty.rs
View File

@ -1,3 +1,8 @@
use std::{
collections::hash_map::DefaultHasher,
hash::{Hash, Hasher},
};
use crate::config::TopConfig;
use gethostname::gethostname;
use pagerduty_rs::types::{AlertTrigger, AlertTriggerPayload};
@ -53,6 +58,15 @@ pub fn pagerduty_alert<T: Serialize>(
let source =
source.unwrap_or_else(|| gethostname().into_string().unwrap_or("unknown".to_string()));
let mut s = DefaultHasher::new();
summary.hash(&mut s);
client.hash(&mut s);
client_url.hash(&mut s);
component.hash(&mut s);
group.hash(&mut s);
class.hash(&mut s);
let dedup_key = s.finish().to_string();
let payload = AlertTriggerPayload {
severity,
summary,
@ -66,7 +80,7 @@ pub fn pagerduty_alert<T: Serialize>(
AlertTrigger {
payload,
dedup_key: None,
dedup_key: Some(dedup_key),
images: None,
links: None,
client: Some(client),