Skip to content

Commit

Permalink
Renames metric that measures updates per bulk
Browse files Browse the repository at this point in the history
Signed-off-by: Klem Yannic (INST/ECS1) <Yannic.Klem@bosch-si.com>
  • Loading branch information
Yannic92 committed Jul 10, 2018
1 parent fa26929 commit d8b05de
Showing 1 changed file with 2 additions and 3 deletions.
Expand Up @@ -53,7 +53,6 @@
import org.eclipse.ditto.services.thingsearch.persistence.write.ThingsSearchUpdaterPersistence;
import org.eclipse.ditto.services.utils.akka.LogUtil;
import org.eclipse.ditto.services.utils.akka.streaming.StreamAck;
import org.eclipse.ditto.services.utils.tracing.MutableKamonTimerBuilder;
import org.eclipse.ditto.services.utils.tracing.MutableKamonTimer;
import org.eclipse.ditto.services.utils.tracing.TraceUtils;
import org.eclipse.ditto.signals.base.ShardedMessageEnvelope;
Expand Down Expand Up @@ -129,7 +128,7 @@ final class ThingUpdater extends AbstractActorWithDiscardOldStash

private static final String TRACE_THING_MODIFIED = "things_search_thing_modified";
private static final String TRACE_THING_BULK_UPDATE = "things_search_thing_bulkUpdate";
private static final String COUNT_THING_BULK_UPDATE = "things_search_thing_bulkUpdate_count";
private static final String COUNT_THING_BULK_UPDATES_PER_BULK = "things_search_thing_bulkUpdate_updates_per_bulk";
private static final String TRACE_THING_DELETE = "things_search_thing_delete";
private static final String TRACE_POLICY_UPDATE = "things_search_policy_update";

Expand Down Expand Up @@ -531,7 +530,7 @@ private void persistThingEvents(final List<ThingEvent> thingEvents, final long t
if (!thingEvents.isEmpty()) {
transactionActive = true;

Kamon.histogram(COUNT_THING_BULK_UPDATE).record(thingEvents.size());
Kamon.histogram(COUNT_THING_BULK_UPDATES_PER_BULK).record(thingEvents.size());

final MutableKamonTimer bulkUpdate = TraceUtils.newTimer(TRACE_THING_BULK_UPDATE).buildStartedTimer();
circuitBreaker.callWithCircuitBreakerCS(() -> searchUpdaterPersistence
Expand Down

0 comments on commit d8b05de

Please sign in to comment.