feat(store): introduce the high level StreamStore for store module

Signed-off-by: daniel-y <[email protected]>

pom.xml

@@ -62,6 +62,11 @@
 
     <dependencyManagement>
         <dependencies>
+            <dependency>
+                <groupId>com.automq.rocketmq</groupId>
+                <artifactId>rocketmq-s3stream</artifactId>
+                <version>${project.version}</version>
+            </dependency>
             <dependency>
                 <groupId>io.grpc</groupId>
                 <artifactId>grpc-bom</artifactId>

store/pom.xml

@@ -54,6 +54,10 @@
             <artifactId>flatbuffers-java</artifactId>
             <version>23.5.26</version>
         </dependency>
+        <dependency>
+            <groupId>com.automq.rocketmq</groupId>
+            <artifactId>rocketmq-s3stream</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

store/src/main/java/com/automq/rocketmq/store/StreamStore.java

@@ -17,9 +17,13 @@
 
 package com.automq.rocketmq.store;
 
-import com.automq.rocketmq.store.model.stream.FetchResult;
-import java.util.UUID;
+import com.automq.rocketmq.stream.api.AppendResult;
+import com.automq.rocketmq.stream.api.FetchResult;
+import com.automq.rocketmq.stream.api.RecordBatch;
+import java.util.concurrent.CompletableFuture;
 
 public interface StreamStore {
-    FetchResult fetch(UUID topicId, int queueId, long offset, int maxCount);
+    CompletableFuture<FetchResult> fetch(long streamId, long startOffset, int maxCount);
+
+    CompletableFuture<AppendResult> append(long streamId, RecordBatch recordBatch);
 }