-
Notifications
You must be signed in to change notification settings - Fork 0
chore(tracing): improve bundle tracing, break when receiver is dropped #115
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
Conversation
This stack of pull requests is managed by Graphite. Learn more about stacking. |
4905988
to
839dc47
Compare
@@ -89,10 +89,12 @@ impl BundlePoller { | |||
.await | |||
.inspect_err(|err| debug!(%err, "Error fetching bundles")) | |||
{ | |||
let _guard = span.entered(); | |||
debug!(count = ?bundles.len(), "found bundles"); | |||
for bundle in bundles.into_iter() { |
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.
could we add a trace or debug log for the bundle id of each bundle?
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.
that should be done in the cache on ingestion, rather than here
src/tasks/cache/task.rs
Outdated
@@ -68,4 +71,25 @@ impl CacheTask { | |||
let fut = self.task_future(sim_cache); | |||
(c, tokio::spawn(fut)) | |||
} | |||
|
|||
/// Utility to log a bundle and its contents. | |||
fn log_bundle(bundle: &TxCacheBundle) { |
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.
per discussion, these events should live in the SDK in SimCache::ingest
I also think these are too verbose.
No description provided.