Complete the log collector (80%).

Author: Davidhua1996

streamis-jobmanager/streamis-job-log/streamis-job-log-collector/pom.xml

@@ -16,4 +16,11 @@
         <maven.compiler.target>8</maven.compiler.target>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>com.webank.wedatasphere.streamis</groupId>
+            <artifactId>streamis-job-log-common</artifactId>
+            <version>0.2.0</version>
+        </dependency>
+    </dependencies>
 </project>

streamis-jobmanager/streamis-job-log/streamis-job-log-collector/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/StreamisLogAppenderConfig.java

@@ -0,0 +1,4 @@
+package com.webank.wedatasphere.streamis.jobmanager.log.collector;
+
+public class StreamisLogAppenderConfig {
+}

streamis-jobmanager/streamis-job-log/streamis-job-log-collector/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/StreamisRpcLogAppender.java

@@ -0,0 +1,5 @@
+package com.webank.wedatasphere.streamis.jobmanager.log.collector;
+
+public class StreamisRpcLogAppender {
+
+}

streamis-jobmanager/streamis-job-log/streamis-job-log-collector/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/cache/LogCache.java

@@ -0,0 +1,43 @@
+package com.webank.wedatasphere.streamis.jobmanager.log.collector.cache;
+
+import com.webank.wedatasphere.streamis.jobmanager.log.entities.LogElement;
+
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Log cache
+ * @param <E> element
+ */
+public interface LogCache<E extends LogElement> {
+
+    /**
+     * Cache log
+     * @param logElement log element
+     */
+    void cacheLog(E logElement) throws InterruptedException;
+
+    /**
+     * Drain log elements into collection
+     * @param elements elements
+     * @param maxElements max elements size
+     * @return count
+     */
+    int drainLogsTo(List<E> elements, int maxElements);
+
+    /**
+     * Take log element
+     * @return log element
+     */
+    E takeLog(long timeout, TimeUnit unit) throws InterruptedException;
+
+    /**
+     * If the cache is full
+     * @return
+     */
+    boolean isCacheable();
+    /**
+     * Release the resource
+     */
+    void destroy();
+}