lib/idempo.rb in idempo-0.1.1 vs lib/idempo.rb in idempo-0.1.2

@@ -39,11 +39,11 @@
     fingerprint = compute_request_fingerprint(req)
     request_key = "#{idempotency_key_header}_#{fingerprint}"
 
     @backend.with_idempotency_key(request_key) do |store|
       if stored_response = store.lookup
-        Measurometer.increment_counter('idempo.served', 1, via: 'cached')
+        Measurometer.increment_counter('idempo.responses_served_from', 1, from: 'store')
         return from_persisted_response(stored_response)
       end
 
       status, headers, body = @app.call(env)
 
@@ -52,11 +52,11 @@
         # Body is replaced with a cached version since a Rack response body is not rewindable
         marshaled_response, body = serialize_response(status, headers, body)
         store.store(data: marshaled_response, ttl: expires_in_seconds)
       end
 
-      Measurometer.increment_counter('idempo.served', 1, via: 'stored')
+      Measurometer.increment_counter('idempo.responses_served_from', 1, from: 'freshly-generated')
       [status, headers, body]
     end
   rescue MalformedIdempotencyKey
     res = {
       ok: false,
@@ -64,10 +64,10 @@
         message: "The Idempotency-Key header provided was empty"
       }
     }
     [400, {'Content-Type' => 'application/json'}, [JSON.pretty_generate(res)]]
   rescue ConcurrentRequest
-    Measurometer.increment_counter('idempo.served', 1, via: 'concurrent-request-error')
+    Measurometer.increment_counter('idempo.responses_served_from', 1, from: 'conflict-concurrent-request')
     res = {
       ok: false,
       error: {
         message: "Another request with this idempotency key is still in progress, please try again later"
       }