add bookkeeper autorecovery dto

pom.xml

@@ -23,9 +23,9 @@
         <checkstyle-plugin.version>3.2.0</checkstyle-plugin.version>
         <javadoc-plugin.version>3.4.1</javadoc-plugin.version>
         <lombok.version>1.18.26</lombok.version>
-        <puppycrawl.version>10.8.0</puppycrawl.version>
+        <puppycrawl.version>10.9.3</puppycrawl.version>
         <release-plugin.version>3.0.0-M6</release-plugin.version>
-        <scm-provider-gitexe.version>1.13.0</scm-provider-gitexe.version>
+        <scm-provider-gitexe.version>2.0.0</scm-provider-gitexe.version>
         <source-plugin.version>3.2.1</source-plugin.version>
         <spotbugs-maven-plugin.version>4.7.2.0</spotbugs-maven-plugin.version>
         <surefire-plugin.version>3.0.0-M9</surefire-plugin.version>

src/main/java/io/github/protocol/bookkeeper/Auditor.java

@@ -0,0 +1,13 @@
+package io.github.protocol.bookkeeper;
+
+public class Auditor {
+    private String auditor;
+
+    public String getAuditor() {
+        return auditor;
+    }
+
+    public void setAuditor(String auditor) {
+        this.auditor = auditor;
+    }
+}

src/main/java/io/github/protocol/bookkeeper/AutoRecovery.java

@@ -0,0 +1,4 @@
+package io.github.protocol.bookkeeper;
+
+public interface AutoRecovery {
+}

src/main/java/io/github/protocol/bookkeeper/AutoRecoveryImpl.java

@@ -0,0 +1,9 @@
+package io.github.protocol.bookkeeper;
+
+public class AutoRecoveryImpl implements AutoRecovery {
+    private final InnerHttpClient innerHttpClient;
+
+    public AutoRecoveryImpl(InnerHttpClient innerHttpClient) {
+        this.innerHttpClient = innerHttpClient;
+    }
+}

src/main/java/io/github/protocol/bookkeeper/AutoRecoveryStatus.java

@@ -0,0 +1,13 @@
+package io.github.protocol.bookkeeper;
+
+public class AutoRecoveryStatus {
+    private boolean enabled;
+
+    public boolean isEnabled() {
+        return enabled;
+    }
+
+    public void setEnabled(boolean enabled) {
+        this.enabled = enabled;
+    }
+}

src/main/java/io/github/protocol/bookkeeper/BookkeeperAdmin.java

@@ -5,5 +5,9 @@ static BookkeeperAdminBuilder builder() {
         return new BookkeeperAdminBuilderImpl();
     }
 
+    Bookies bookies();
+
+    AutoRecovery autoRecovery();
+
     Heartbeat heartbeat();
 }

src/main/java/io/github/protocol/bookkeeper/BookkeeperAdminImpl.java

@@ -1,12 +1,28 @@
 package io.github.protocol.bookkeeper;
 
 public class BookkeeperAdminImpl implements BookkeeperAdmin {
+    private final BookiesImpl bookies;
+
+    private final AutoRecovery autoRecovery;
+
     private final Heartbeat heartbeat;
     BookkeeperAdminImpl(Configuration conf) {
         InnerHttpClient innerHttpClient = new InnerHttpClient(conf);
+        this.bookies = new BookiesImpl(innerHttpClient);
+        this.autoRecovery = new AutoRecoveryImpl(innerHttpClient);
         this.heartbeat = new HeartbeatImpl(innerHttpClient);
     }
 
+    @Override
+    public Bookies bookies() {
+        return bookies;
+    }
+
+    @Override
+    public AutoRecovery autoRecovery() {
+        return autoRecovery;
+    }
+
     @Override
     public Heartbeat heartbeat() {
         return heartbeat;

src/main/java/io/github/protocol/bookkeeper/ListUnderReplicatedLedgerReqData.java

@@ -0,0 +1,31 @@
+package io.github.protocol.bookkeeper;
+
+public class ListUnderReplicatedLedgerReqData {
+    private String includingBookieId;
+    private String excludingBookieId;
+    private boolean printMissingReplica;
+
+    public String getIncludingBookieId() {
+        return includingBookieId;
+    }
+
+    public void setIncludingBookieId(String includingBookieId) {
+        this.includingBookieId = includingBookieId;
+    }
+
+    public String getExcludingBookieId() {
+        return excludingBookieId;
+    }
+
+    public void setExcludingBookieId(String excludingBookieId) {
+        this.excludingBookieId = excludingBookieId;
+    }
+
+    public boolean isPrintMissingReplica() {
+        return printMissingReplica;
+    }
+
+    public void setPrintMissingReplica(boolean printMissingReplica) {
+        this.printMissingReplica = printMissingReplica;
+    }
+}

src/main/java/io/github/protocol/bookkeeper/RecoveryBookieReqData.java

@@ -0,0 +1,24 @@
+package io.github.protocol.bookkeeper;
+
+import java.util.List;
+
+public class RecoveryBookieReqData {
+    private List<String> bookieSrc;
+    private boolean deleteCookie;
+
+    public List<String> getBookieSrc() {
+        return bookieSrc;
+    }
+
+    public void setBookieSrc(List<String> bookieSrc) {
+        this.bookieSrc = bookieSrc;
+    }
+
+    public boolean isDeleteCookie() {
+        return deleteCookie;
+    }
+
+    public void setDeleteCookie(boolean deleteCookie) {
+        this.deleteCookie = deleteCookie;
+    }
+}

src/main/java/io/github/protocol/bookkeeper/UnderReplicatedLedger.java

@@ -0,0 +1,15 @@
+package io.github.protocol.bookkeeper;
+
+import java.util.List;
+
+public class UnderReplicatedLedger {
+    private List<Long> ledgers;
+
+    public List<Long> getLedgers() {
+        return ledgers;
+    }
+
+    public void setLedgers(List<Long> ledgers) {
+        this.ledgers = ledgers;
+    }
+}

src/test/java/io/github/protocol/bookkeeper/AutoRecoveryImplTest.java

@@ -0,0 +1,26 @@
+package io.github.protocol.bookkeeper;
+
+import io.github.embedded.bookkeeper.core.EmbeddedBookkeeperServer;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+
+public class AutoRecoveryImplTest {
+
+    private static final EmbeddedBookkeeperServer SERVER = new EmbeddedBookkeeperServer();
+
+    private static AutoRecoveryImpl autoRecovery = null;
+
+    @BeforeAll
+    public static void setup() throws Exception {
+        SERVER.start();
+        Configuration conf = new Configuration();
+        conf.setHost("localhost");
+        conf.setPort(SERVER.getBkWebPort());
+        autoRecovery = new AutoRecoveryImpl(new InnerHttpClient(conf));
+    }
+
+    @AfterAll
+    public static void teardown() throws Exception {
+        SERVER.close();
+    }
+}