Dev

[ms-0o0]

개요

트래픽 제너레이터 처리 tps 커스텀 메트릭스 추가

관련 BackLog

Resolves: 463

PR 유형

• 새로운 기능 추가
• 버그 수정
• CSS 등 사용자 UI 디자인 변경
• 코드에 영향을 주지 않는 변경사항(오타 수정, 탭 사이즈 변경, 변수명 변경)
• 코드 리팩토링
• 주석 추가 및 수정
• 문서 수정
• 테스트 추가, 테스트 리팩토링
• 빌드 부분 혹은 패키지 매니저 수정
• 파일 혹은 폴더명 수정
• 파일 혹은 폴더 삭제

PR Checklist

• 커밋 메시지 컨벤션에 맞게 작성했습니다.
• 변경 사항에 대한 테스트를 했습니다.(버그 수정/기능에 대한 테스트).

Summary by CodeRabbit

Release Notes

• New Features
  • Introduced real-time transactions-per-second (TPS) metric for traffic processing monitoring.
  • Added latency tracking and measurement for individual record processing events to improve performance visibility and diagnostics.
  • Implemented automatic per-second metric collection and reset functionality for continuous performance monitoring.

[coderabbitai]

Caution

Review failed

The pull request is closed.

ℹ️ Recent review info

⚙️ Run configuration

Configuration used: defaults

Review profile: CHILL

Plan: Pro

Run ID: fa07867e-60cc-4402-aeef-563dd30a9002

📥 Commits

Reviewing files that changed from the base of the PR and between 1329c37 and b9462c4.

📒 Files selected for processing (2)

• src/main/java/com/pooli/monitoring/metrics/TrafficGeneratorMetrics.java
• src/main/java/com/pooli/traffic/service/invoke/TrafficStreamConsumerRunner.java

---

📝 Walkthrough

Walkthrough

This change introduces per-second TPS (transactions per second) metrics tracking in the traffic generator monitoring system. A new gauge metric is exposed via TrafficGeneratorMetrics that counts processed records, resetting every second via a scheduled task. The traffic stream consumer integration point increments this counter for each successfully processed record.

Changes

Cohort / File(s)	Summary
Metrics Infrastructure src/main/java/com/pooli/monitoring/metrics/TrafficGeneratorMetrics.java	Added AtomicInteger counter for current-second processed records, Gauge metric registration for TPS exposure, scheduled task to reset counter every second, and public increment method.
Metrics Integration src/main/java/com/pooli/traffic/service/invoke/TrafficStreamConsumerRunner.java	Integrated TrafficGeneratorMetrics dependency into record processing pipeline; calls incrementProcessed() after successful in-flight release to track per-record metrics.

Estimated code review effort

🎯 2 (Simple) | ⏱️ ~12 minutes

Poem

🐰 Hopping through traffic, one hop per tick,
Every second resets with metrics so slick,
Gauge spinning merrily, counting our pace,
Records processed all over the place! ✨📊

✨ Finishing Touches

• 📝 Generate docstrings (stacked PR)
• 📝 Generate docstrings (commit on current branch)

🧪 Generate unit tests (beta)

• Create PR with unit tests
• Commit unit tests in branch dev

📝 Coding Plan

• Generate coding plan for human review comments

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}