xmtp_mls_core/metrics.rs
1use crate::worker::metrics::WorkerMetrics;
2
3#[derive(PartialEq, Eq, Hash, Clone, Copy, Debug)]
4pub enum SyncMetric {
5 Init,
6 SyncGroupCreated,
7 HmacSent,
8 HmacReceived,
9 ConsentSent,
10 ConsentReceived,
11}
12
13impl WorkerMetrics<SyncMetric> {
14 pub async fn wait_for_init(&self) -> Result<(), xmtp_common::time::Expired> {
15 self.register_interest(SyncMetric::Init, 1).wait().await
16 }
17}