Module: MagicPipe::Senders::MetricsMixin

Included in:
Async::Worker, Sync
Defined in:
lib/magic_pipe/senders/metrics_mixin.rb

Instance Method Summary collapse

Instance Method Details

#track_failure(metrics, topic) ⇒ Object 



11
12
13
14
15
16
 
# File 'lib/magic_pipe/senders/metrics_mixin.rb', line 11

def track_failure(metrics, topic)
  metrics.increment(
    "magic_pipe.senders.failure",
    tags: ["topic:#{topic}"]
  )
end

#track_success(metrics, topic) ⇒ Object 



4
5
6
7
8
9
 
# File 'lib/magic_pipe/senders/metrics_mixin.rb', line 4

def track_success(metrics, topic)
  metrics.increment(
    "magic_pipe.senders.mgs_sent",
    tags: ["topic:#{topic}"]
  )
end