Module: Harness::ActivePublisher

Defined in:

lib/harness/active_publisher.rb,
lib/harness/active_publisher/version.rb

Constant Summary

DROPPED_METRIC =

["active_publisher", ENV["SERVICE_NAME"], "message_dropped"].reject(&:nil?).join(".").freeze

LATENCY_METRIC =

["active_publisher", ENV["SERVICE_NAME"], "publish_latency"].reject(&:nil?).join(".").freeze

PUBLISHED_METRIC =

["active_publisher", ENV["SERVICE_NAME"], "messages_published"].reject(&:nil?).join(".").freeze

QUEUE_SIZE_METRIC =

["active_publisher", ENV["SERVICE_NAME"], "async_queue_size"].reject(&:nil?).join(".").freeze

REDIS_QUEUE_SIZE_METRIC =

["active_publisher", ENV["SERVICE_NAME"], "redis_async_queue_size"].reject(&:nil?).join(".").freeze

WAIT_METRIC =

["active_publisher", ENV["SERVICE_NAME"], "waiting_for_async_queue"].reject(&:nil?).join(".").freeze

VERSION =

"1.1.1"