-
Notifications
You must be signed in to change notification settings - Fork 10
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: add pipeline metrics #646
Conversation
Adds metrics for the pipeline system. Support was added to the actor framework to directly support metrics.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nice. The generic bounds on the Actor trait are a bit rough, but the requirements/impl is captured by the macros so it shouldn't be necessary to think about/look at them very often.
actor/src/macros.rs
Outdated
pub trait $trait_name : $crate::Actor<Envelope = $enum_name> $( + $crate::Handler<$message_type> )* { } | ||
pub trait $actor_trait : $crate::Actor<Envelope = $enum_name> $( + $crate::Handler<$message_type> )* + ::std::marker::Send + 'static { } | ||
|
||
#[doc = std::stringify!($actor_trait)] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this should be$recorder_trait
mut shutdown: ShutdownSignal, | ||
) -> anyhow::Result<()> { | ||
let mut interval = interval(Duration::from_millis(1_000)); | ||
interval.set_missed_tick_behavior(MissedTickBehavior::Skip); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍
Adds metrics for the pipeline system. Support was added to the actor framework to directly support metrics.
Fixes #582