Skip to content

Commit

Permalink
rename metrics of search service to avoid collisions with previous se…
Browse files Browse the repository at this point in the history
…rvice

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
  • Loading branch information
dguggemos committed Apr 13, 2022
1 parent a3fc872 commit f2e92e9
Show file tree
Hide file tree
Showing 8 changed files with 14 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,9 +45,9 @@ public final class ThingWriteModel extends AbstractWriteModel {

private static final ThreadSafeDittoLogger LOGGER = DittoLoggerFactory.getThreadSafeLogger(ThingUpdater.class);

private static final Counter PATCH_UPDATE_COUNT = DittoMetrics.counter("search_patch_updates");
private static final Counter PATCH_SKIP_COUNT = DittoMetrics.counter("search_patch_skips");
private static final Counter FULL_UPDATE_COUNT = DittoMetrics.counter("search_full_updates");
private static final Counter PATCH_UPDATE_COUNT = DittoMetrics.counter("wildcard_search_patch_updates");
private static final Counter PATCH_SKIP_COUNT = DittoMetrics.counter("wildcard_search_patch_skips");
private static final Counter FULL_UPDATE_COUNT = DittoMetrics.counter("wildcard_search_full_updates");

private final BsonDocument thingDocument;
private final boolean isPatchUpdate;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@
*/
public final class BulkWriteResultAckFlow {

private static final Counter ERRORS_COUNTER = DittoMetrics.counter("search-index-update-errors");
private static final Counter ERRORS_COUNTER = DittoMetrics.counter("wildcard-search-index-update-errors");

private static final ThreadSafeDittoLogger LOGGER =
DittoLoggerFactory.getThreadSafeLogger(BulkWriteResultAckFlow.class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ public final class ConsistencyLag {
/**
* Name of the search updater consistency lag timer.
*/
public static final String TIMER_NAME = "things_search_updater_consistency_lag";
public static final String TIMER_NAME = "things_wildcard_search_updater_consistency_lag";

/**
* Tag for differentiating between search updates requiring acks and those who not require them.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,8 +49,8 @@
*/
final class MongoSearchUpdaterFlow {

private static final String TRACE_THING_BULK_UPDATE = "things_search_thing_bulkUpdate";
private static final String COUNT_THING_BULK_UPDATES_PER_BULK = "things_search_thing_bulkUpdate_updates_per_bulk";
private static final String TRACE_THING_BULK_UPDATE = "things_wildcard_search_thing_bulkUpdate";
private static final String COUNT_THING_BULK_UPDATES_PER_BULK = "things_wildcard_search_thing_bulkUpdate_updates_per_bulk";
private static final String UPDATE_TYPE_TAG = "update_type";

private static final ThreadSafeDittoLogger LOGGER =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@
*/
public final class MongoClientExtension implements Extension {

private static final String SEARCH_PREFIX = "search";
private static final String UPDATER_PREFIX = "updater";
private static final String SEARCH_PREFIX = "wildcard_search";
private static final String UPDATER_PREFIX = "wildcard_updater";
private static final Id EXTENSION_ID = new Id();

private final DittoMongoClient mongoClient;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ public final class SearchActor extends AbstractActor {

private static final String SEARCH_DISPATCHER_ID = "search-dispatcher";

private static final String TRACING_THINGS_SEARCH = "things_search_query";
private static final String TRACING_THINGS_SEARCH = "things_wildcard_search_query";
private static final String QUERY_PARSING_SEGMENT_NAME = "query_parsing";
private static final String DATABASE_ACCESS_SEGMENT_NAME = "database_access";
private static final String QUERY_TYPE_TAG = "query_type";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,8 +65,8 @@ public final class BackgroundSyncActor
private final BackgroundSyncStream backgroundSyncStream;
private final ActorRef thingsUpdater;

private final Counter streamedSnapshots = DittoMetrics.counter("search_streamed_snapshots");
private final Counter scannedIndexDocs = DittoMetrics.counter("search_scanned_index_docs");
private final Counter streamedSnapshots = DittoMetrics.counter("wildcard_search_streamed_snapshots");
private final Counter scannedIndexDocs = DittoMetrics.counter("wildcard_search_scanned_index_docs");

private ThingId progressPersisted = EMPTY_THING_ID;
private ThingId progressIndexed = EMPTY_THING_ID;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,8 +81,8 @@
*/
public final class ThingUpdater extends AbstractFSMWithStash<ThingUpdater.State, ThingUpdater.Data> {

private static final Counter INCORRECT_PATCH_UPDATE_COUNT = DittoMetrics.counter("search_incorrect_patch_updates");
private static final Counter UPDATE_FAILURE_COUNT = DittoMetrics.counter("search_update_failures");
private static final Counter INCORRECT_PATCH_UPDATE_COUNT = DittoMetrics.counter("wildcard_search_incorrect_patch_updates");
private static final Counter UPDATE_FAILURE_COUNT = DittoMetrics.counter("wildcard_search_update_failures");

private static final Duration BLOCK_NAMESPACE_SHUTDOWN_DELAY = Duration.ofMinutes(2);

Expand Down

0 comments on commit f2e92e9

Please sign in to comment.