✨ add job container

Author: songxiaosheng

.gitignore

@@ -1,3 +1,4 @@
 /.idea/
 *.iml
-*/target
+*/target
+/.fleet/

pom.xml

@@ -5,26 +5,15 @@
   <modelVersion>4.0.0</modelVersion>
 
   <groupId>com.slicingflow</groupId>
-  <artifactId>SlicingFlow</artifactId>
+  <artifactId>ScalableJob</artifactId>
   <packaging>pom</packaging>
   <version>1.0-SNAPSHOT</version>
   <modules>
-    <module>slicing-flow-common</module>
-    <module>slicing-flow-config</module>
-    <module>slicing-flow-core</module>
-    <module>slicing-flow-spring</module>
-    <module>slicing-flow-springboot</module>
-    <module>slicing-flow-metrics</module>
-    <module>slicing-flow-remote</module>
-    <module>slicing-flow-test</module>
-      <module>slicing-flow-protocol</module>
-      <module>slicing-flow-cluster</module>
-    <module>slicing-flow-console</module>
+    <module>scalable-job-core</module>
   </modules>
 
-  <name>SlicingFlow</name>
-  <!-- FIXME change it to the project's website -->
-  <url>http://www.example.com</url>
+  <name>ScalableJob</name>
+  <url></url>
 
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

slicing-flow-core/pom.xml scalable-job-core/pom.xml

@@ -5,7 +5,7 @@
   <modelVersion>4.0.0</modelVersion>
 
   <groupId>com.slicingflow</groupId>
-  <artifactId>slicing-flow-core</artifactId>
+  <artifactId>scalable-job-core</artifactId>
   <version>1.0-SNAPSHOT</version>
 
   <name>slicing-flow-core</name>
@@ -25,6 +25,12 @@
       <version>4.11</version>
       <scope>test</scope>
     </dependency>
+    <!-- https://mvnrepository.com/artifact/org.quartz-scheduler/quartz -->
+    <dependency>
+      <groupId>org.quartz-scheduler</groupId>
+      <artifactId>quartz</artifactId>
+      <version>2.3.2</version>
+    </dependency>
   </dependencies>
 
   <build>

scalable-job-core/src/main/java/link/elastic/job/core/JobContainer.java

@@ -0,0 +1,12 @@
+package link.elastic.job.core;
+
+import link.elastic.job.core.config.JobConfig;
+
+public interface JobContainer {
+
+    void add(JobConfig jobConfig);
+
+    void remove(JobConfig jobConfig);
+
+
+}

scalable-job-core/src/main/java/link/elastic/job/core/config/JobConfig.java

@@ -0,0 +1,4 @@
+package link.elastic.job.core.config;
+
+public interface JobConfig {
+}

scalable-job-core/src/main/java/link/elastic/job/core/container/DefaultJobContainer.java

@@ -0,0 +1,21 @@
+package link.elastic.job.core.container;
+
+import link.elastic.job.core.JobContainer;
+import link.elastic.job.core.config.JobConfig;
+
+import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+public class DefaultJobContainer implements JobContainer {
+    private final List<JobConfig> jobConfigMap = new CopyOnWriteArrayList<>();
+    @Override
+    public void add(JobConfig jobConfig) {
+        jobConfigMap.add(jobConfig);
+    }
+
+    @Override
+    public void remove(JobConfig jobConfig) {
+        jobConfigMap.remove(jobConfig);
+    }
+}