goto / compass

87%

main: 81%

LAST BUILD ON BRANCH worker-instrumentation

branch: worker-instrumentation

CHANGE BRANCH

x

Reset

Sync Branches

• worker-instrumentation
• 64/query-asset-type
• adjustable-sync-timeout
• api-server-metrics
• asset-probes-order-by-ts
• buf-deprecated-plugins
• bump-otelsql
• code-coverage
• col_search
• configure-golangci-lint
• create-asset-with-owner-uuid
• db-stats-attrs
• dead-job-management
• delete-lineage
• disable-fuzzy-search
• discovery-delete-ignore-unavailable
• docs-delete-assets-api
• elasticsearch-request-timeout-increase
• empty_text_search
• enable_include_fields
• english_stemmer
• es-ignore-malformed
• es-use-universe
• exact_match
• feat-additional-types
• feat-configurable-time-out-in-delete-assets
• feat-create-delete-assets-api
• feat-deprecate-uuid-users
• feat-es-provide-password
• feat-optional-attributes
• feat/add-is-deleted-get-api
• feat/add-is-deleted-search-api
• feat/add-user-context-to-logger
• feat/all-soft-deletion
• feat/hard-deletion-mech
• feat/introduce-metric-type
• feat/search-ranking
• feat/soft-deletion
• feat/soft-deletion-by-query
• feat/support-experiment-type
• feat/support-large-number-delete-by-query
• feat/update-only-upsert-api
• feat/use-tx-for-upsert
• fix-asset-versions-sort
• fix-create-index-race
• fix-goreleaser
• fix-linter
• fix-nil-es-query
• fix-proton-commit-vn
• fix-upsert-race-condition
• fix-version-0.1
• fix/discovery-repo-upsert-error-handling
• fix/golang-ci-lint-issues
• fix/grpc-server-msg-size
• fix/lineage-api-default
• fix/upsert-assets-nested-data-not-updated
• fix/upsert-patch-elasticsearch
• getassets
• golangci-lint-minimal-fixes
• gorelease-version
• goreleaser-flag-update
• group_assets
• handle-dup-owner
• highlight
• idx-asset-probes
• log-malformed-upsert
• main
• match_phrase
• memory-optimize-delete-asset
• nested_query
• open-telemetry
• optimize-delete-asset-memory-usage
• pagination-search-assets
• pgq-worker
• probe-optional-id
• purge-statsd-and-telegraf
• refactor/goto
• refs/tags/v0.5.0
• refs/tags/v0.5.0-rc1
• refs/tags/v0.5.1
• refs/tags/v0.5.2
• refs/tags/v0.5.3
• refs/tags/v0.5.4
• refs/tags/v0.5.5
• refs/tags/v0.5.6
• refs/tags/v0.5.7
• refs/tags/v0.6.0
• refs/tags/v0.6.1
• refs/tags/v0.6.2
• refs/tags/v0.6.3
• refs/tags/v0.6.4
• refs/tags/v0.6.5
• refs/tags/v0.7.0
• refs/tags/v0.7.1
• refs/tags/v0.7.10
• refs/tags/v0.7.11
• refs/tags/v0.7.2
• refs/tags/v0.7.3
• refs/tags/v0.7.4
• refs/tags/v0.7.5
• refs/tags/v0.7.6
• refs/tags/v0.7.7
• refs/tags/v0.7.8
• refs/tags/v0.7.9
• refs/tags/v0.8.0
• refs/tags/v0.8.1
• refs/tags/v0.8.2
• refs/tags/v0.9.0
• refs/tags/v0.9.1
• refs/tags/v0.9.2
• refs/tags/v0.9.3
• refs/tags/v0.9.4
• refs/tags/v0.9.5
• refs/tags/v0.9.6
• regenerate-mocks
• repo-set-create-updated-at-fields
• statsd-datadog-format
• sync-asset
• test-statsd-format
• update_timeouts
• upsert-no-fetch-probes
• worker-ping-handler
• worker-poll-backoff

Build # 5781397882

Build Type

Pull #50

github

Committed by sudo-suhas

Commit Message

feat: instrument worker with OpenTelemetry

- 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

Pull Request Pull Request #50: feat: instrument worker with OpenTelemetry

Run Details

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