Skip to content

Commit

Permalink
Web Scheduler
Browse files Browse the repository at this point in the history
  • Loading branch information
silentbalanceyh committed Apr 19, 2024
1 parent 1ba22ac commit 1f0541b
Show file tree
Hide file tree
Showing 7 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.mature.extension.scaffold.component;

import io.vertx.up.annotations.Contract;
import io.zerows.mbse.atom.worker.Mission;
import io.zerows.web.metadata.atom.worker.Mission;

/**
* ## 「Actor」顶层调度器
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.mature.extension.scaffold.component;

import io.vertx.up.annotations.Contract;
import io.zerows.mbse.atom.worker.Mission;
import io.zerows.web.metadata.atom.worker.Mission;

/**
* ## 「Director」顶层执行器
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,11 @@
import io.vertx.mod.jet.refine.Jt;
import io.vertx.mod.jet.uca.business.AbstractJob;
import io.vertx.up.annotations.Contract;
import io.zerows.mbse.atom.worker.Mission;
import io.zerows.mbse.commune.Envelop;
import io.vertx.up.eon.KWeb;
import io.vertx.up.uca.job.plugin.JobIncome;
import io.vertx.up.unity.Ux;
import io.zerows.mbse.commune.Envelop;
import io.zerows.web.metadata.atom.worker.Mission;

/**
* ## 「KIncome」顶层任务前置器
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,9 +11,9 @@
import io.vertx.mod.jet.refine.Jt;
import io.vertx.mod.jet.uca.business.AbstractJob;
import io.vertx.up.annotations.Contract;
import io.zerows.mbse.atom.worker.Mission;
import io.vertx.up.uca.job.plugin.JobOutcome;
import io.vertx.up.unity.Ux;
import io.zerows.web.metadata.atom.worker.Mission;

/**
* ## 「KIncome」顶层任务后置器
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,9 @@
import io.vertx.up.unity.Ux;
import io.vertx.up.util.Ut;
import io.zerows.core.feature.database.atom.Database;
import io.zerows.mbse.atom.worker.Mission;
import io.zerows.mbse.commune.ActIn;
import io.zerows.mbse.commune.ActOut;
import io.zerows.web.metadata.atom.worker.Mission;

import java.util.Objects;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,9 @@
import io.vertx.core.MultiMap;
import io.vertx.core.json.JsonObject;
import io.vertx.up.eon.KName;
import io.vertx.up.eon.KWeb;
import io.vertx.up.unity.Ux;
import io.zerows.core.feature.database.atom.Database;
import io.zerows.feature.web.cache.RapidKey;

/**
* @author <a href="http://www.origin-x.cn">Lang</a>
Expand Down Expand Up @@ -55,7 +55,7 @@ public HArk configArk() {
@Override
public Future<KFabric> fabric(final String identifier) {
final MultiMap params = this.input(identifier);
params.add(KName.CACHE_KEY, RapidKey.JOB_DIRECTORY);
params.add(KName.CACHE_KEY, KWeb.CACHE.JOB_DIRECTORY);
final KDictConfig dict = this.configDict();
return Ux.dictAtom(dict, params, this.map(), identifier);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@
import io.vertx.up.unity.Ux;
import io.vertx.up.util.Ut;
import io.zerows.core.metadata.store.config.OZeroStore;
import io.zerows.mbse.atom.worker.Mission;
import io.zerows.mbse.commune.Envelop;
import io.zerows.web.metadata.atom.worker.Mission;
import io.zerows.web.metadata.zdk.Commercial;

import java.util.Objects;
Expand Down

0 comments on commit 1f0541b

Please sign in to comment.