DatabaseChecks class was renamed to DatabaseChecksOnCluster

pg-index-health-logger/src/main/java/io/github/mfvanek/pg/health/logger/AbstractHealthLogger.java

@@ -57,14 +57,14 @@ public abstract class AbstractHealthLogger implements HealthLogger {
 
     private final ConnectionCredentials credentials;
     private final HighAvailabilityPgConnectionFactory connectionFactory;
-    private final Function<HighAvailabilityPgConnection, DatabaseChecks> databaseChecksFactory;
-    private final AtomicReference<DatabaseChecks> databaseChecksHolder = new AtomicReference<>();
+    private final Function<HighAvailabilityPgConnection, DatabaseChecksOnCluster> databaseChecksFactory;
+    private final AtomicReference<DatabaseChecksOnCluster> databaseChecksHolder = new AtomicReference<>();
     private final AtomicReference<PgContext> pgContextHolder = new AtomicReference<>();
 
     @SuppressWarnings("WeakerAccess")
     protected AbstractHealthLogger(@Nonnull final ConnectionCredentials credentials,
                                    @Nonnull final HighAvailabilityPgConnectionFactory connectionFactory,
-                                   @Nonnull final Function<HighAvailabilityPgConnection, DatabaseChecks> databaseChecksFactory) {
+                                   @Nonnull final Function<HighAvailabilityPgConnection, DatabaseChecksOnCluster> databaseChecksFactory) {
         this.credentials = Objects.requireNonNull(credentials, "credentials cannot be null");
         this.connectionFactory = Objects.requireNonNull(connectionFactory, "connectionFactory cannot be null");
         this.databaseChecksFactory = Objects.requireNonNull(databaseChecksFactory, "databaseChecksFactory cannot be null");

pg-index-health-logger/src/main/java/io/github/mfvanek/pg/health/logger/DatabaseChecks.java → pg-index-health-logger/src/main/java/io/github/mfvanek/pg/health/logger/DatabaseChecksOnCluster.java

@@ -50,11 +50,11 @@
 
 @SuppressWarnings({"checkstyle:ClassDataAbstractionCoupling", "checkstyle:ClassFanOutComplexity"})
 @ThreadSafe
-public class DatabaseChecks {
+public final class DatabaseChecksOnCluster {
 
     private final ConcurrentMap<Diagnostic, DatabaseCheckOnCluster<? extends DbObject>> checks = new ConcurrentHashMap<>();
 
-    public DatabaseChecks(@Nonnull final HighAvailabilityPgConnection haPgConnection) {
+    public DatabaseChecksOnCluster(@Nonnull final HighAvailabilityPgConnection haPgConnection) {
         final Stream<DatabaseCheckOnCluster<? extends DbObject>> allChecks = Stream.of(
             new TablesWithBloatCheckOnCluster(haPgConnection),
             new TablesWithMissingIndexesCheckOnCluster(haPgConnection),

pg-index-health-logger/src/main/java/io/github/mfvanek/pg/health/logger/KeyValueFileHealthLogger.java

@@ -47,7 +47,7 @@ public class KeyValueFileHealthLogger extends AbstractHealthLogger {
 
     public KeyValueFileHealthLogger(@Nonnull final ConnectionCredentials credentials,
                                     @Nonnull final HighAvailabilityPgConnectionFactory connectionFactory,
-                                    @Nonnull final Function<HighAvailabilityPgConnection, DatabaseChecks> databaseChecksFactory) {
+                                    @Nonnull final Function<HighAvailabilityPgConnection, DatabaseChecksOnCluster> databaseChecksFactory) {
         super(credentials, connectionFactory, databaseChecksFactory);
     }
 

pg-index-health-logger/src/main/java/io/github/mfvanek/pg/health/logger/StandardHealthLogger.java

@@ -26,7 +26,7 @@ public class StandardHealthLogger extends AbstractHealthLogger {
 
     public StandardHealthLogger(@Nonnull final ConnectionCredentials credentials,
                                 @Nonnull final HighAvailabilityPgConnectionFactory connectionFactory,
-                                @Nonnull final Function<HighAvailabilityPgConnection, DatabaseChecks> databaseChecksFactory) {
+                                @Nonnull final Function<HighAvailabilityPgConnection, DatabaseChecksOnCluster> databaseChecksFactory) {
         super(credentials, connectionFactory, databaseChecksFactory);
     }
 

pg-index-health-logger/src/test/java/io/github/mfvanek/pg/health/logger/DatabaseChecksTest.java → pg-index-health-logger/src/test/java/io/github/mfvanek/pg/health/logger/DatabaseChecksOnClusterTest.java

@@ -30,11 +30,11 @@
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
-class DatabaseChecksTest extends DatabaseAwareTestBase {
+class DatabaseChecksOnClusterTest extends DatabaseAwareTestBase {
 
     private static final String[] SCHEMAS = {PgContext.DEFAULT_SCHEMA_NAME, "custom"};
 
-    private final DatabaseChecks checks = new DatabaseChecks(getHaPgConnection());
+    private final DatabaseChecksOnCluster checks = new DatabaseChecksOnCluster(getHaPgConnection());
 
     @Test
     void shouldThrowExceptionForInvalidType() {
@@ -62,7 +62,7 @@ void getAllChecksShouldWork() {
     @Test
     @SuppressForbidden
     void shouldThrowExceptionIfCheckNotFound() throws NoSuchFieldException, IllegalAccessException, NoSuchMethodException, InvocationTargetException {
-        final DatabaseChecks databaseChecks = new DatabaseChecks(getHaPgConnection());
+        final DatabaseChecksOnCluster databaseChecks = new DatabaseChecksOnCluster(getHaPgConnection());
         final Field field = databaseChecks.getClass().getDeclaredField("checks");
         field.setAccessible(true);
         final Object fieldValue = field.get(databaseChecks);

pg-index-health-logger/src/test/java/io/github/mfvanek/pg/health/logger/HealthLoggerTest.java

@@ -47,7 +47,7 @@ static void tearDown() {
     @Nonnull
     @Override
     protected HealthLogger getHealthLogger() {
-        return new KeyValueFileHealthLogger(getConnectionCredentials(), getConnectionFactory(), DatabaseChecks::new);
+        return new KeyValueFileHealthLogger(getConnectionCredentials(), getConnectionFactory(), DatabaseChecksOnCluster::new);
     }
 
     @Nonnull

pg-index-health-logger/src/test/java/io/github/mfvanek/pg/health/logger/StandardHealthLoggerTest.java

@@ -19,7 +19,7 @@ class StandardHealthLoggerTest extends HealthLoggerTestBase {
     @Nonnull
     @Override
     protected HealthLogger getHealthLogger() {
-        return new StandardHealthLogger(getConnectionCredentials(), getConnectionFactory(), DatabaseChecks::new);
+        return new StandardHealthLogger(getConnectionCredentials(), getConnectionFactory(), DatabaseChecksOnCluster::new);
     }
 
     @Nonnull