goto / compass / 5781465228

81%

push

github

feat: instrument worker with OpenTelemetry (#50)

- Add Stats(...) method to JobProcessor to allow tracking counts of
  active and dead jobs by job type.
- Add JobProcessor middleware for OpenTelemetry instrumentation.
- Add middlewares to handlers for dead job managers's endpoints.
- Add histogram compass.worker.jobs.enqueue.duration with the following
  attributes:
  - job.types: ["index-asset", "delete-asset"]
  - operation.success: true/false
- Add gauge compass.worker.active_jobs with the following attributes:
  - job.type: index-asset/delete-asset
- Add histogram compass.worker.job.dequeue.latency with the following
  attributes:
  - job.type: index-asset/delete-asset
- Add histogram compass.worker.job.process.duration with the following
  attributes:
  - job.type: index-asset/delete-asset
  - job.attempt_number: 1/2
  - job.status: done/dead/retry
  - operation.success: true/false
- Add gauge compass.worker.dead_jobs with the following attributes:
  - job.type: index-asset/delete-asset

96 of 96 new or added lines in 3 files covered. (100.0%)

6161 of 7058 relevant lines covered (87.29%)

21.93 hits per line