Skip to content

Commit f9bc2c5

Browse files
authored
oximeter: consistent logging for producer/consumer details. (#9368)
Nit: Update CollectionTask logs to include the producer ip and port, to match oximeter stats and consumer details in the existing logs. This isn't important—I just noticed a mismatch between producer/consumer logging attributes, and we also include consumer details in oximeter's metrics about itself.
1 parent cc8b868 commit f9bc2c5

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

oximeter/collector/src/collection_task.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -381,6 +381,8 @@ impl CollectionTaskHandle {
381381
let log = log.new(o!(
382382
"component" => "collection-task-handle",
383383
"producer_id" => producer.id.to_string(),
384+
"producer_ip" => producer.address.ip().to_string(),
385+
"producer_port" => producer.address.port(),
384386
));
385387
Self { notifiers, log }
386388
}
@@ -536,6 +538,8 @@ impl CollectionTask {
536538
let log = log.new(o!(
537539
"component" => "collection-task",
538540
"producer_id" => producer.id.to_string(),
541+
"producer_ip" => producer.address.ip().to_string(),
542+
"producer_port" => producer.address.port(),
539543
));
540544

541545
// Watch channel for changes to the producer's endpoint information.

0 commit comments

Comments
 (0)