Merge branch 'master' into yyang/bundle-catalog

Author: fantapsody

mesh-worker-service/README.md

@@ -17,11 +17,6 @@ functionsWorkerServiceNarPackage: /YOUR-NAR-PATH/mesh-worker-service-1.0-SNAPSHO
 ```
 Replace the `YOUR-NAR-PATH` variable with your real path.
 
-#### Start pulsar service
-
-```$xslt
-./bin/pulsar standalone -a 127.0.0.1 -nss
-```
 
 ### Configuring the development environment
 

mesh-worker-service/src/main/java/io/functionmesh/compute/models/CustomRuntimeOptions.java

@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package io.functionmesh.proxy.models;
+package io.functionmesh.compute.models;
 
 import lombok.Data;
 

mesh-worker-service/src/main/java/io/functionmesh/compute/util/FunctionsUtil.java

@@ -19,7 +19,7 @@
 package io.functionmesh.compute.util;
 
 import io.functionmesh.compute.functions.models.*;
-import io.functionmesh.proxy.models.CustomRuntimeOptions;
+import io.functionmesh.compute.models.CustomRuntimeOptions;
 import io.kubernetes.client.openapi.models.V1ObjectMeta;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.pulsar.common.functions.ConsumerConfig;

mesh-worker-service/src/main/java/io/functionmesh/compute/util/SinksUtil.java

@@ -25,7 +25,7 @@
 import io.functionmesh.compute.sinks.models.V1alpha1SinkSpecJava;
 import io.functionmesh.compute.sinks.models.V1alpha1SinkSpecPulsar;
 import io.functionmesh.compute.sinks.models.V1alpha1SinkSpecResources;
-import io.functionmesh.proxy.models.CustomRuntimeOptions;
+import io.functionmesh.compute.models.CustomRuntimeOptions;
 import io.kubernetes.client.openapi.models.V1ObjectMeta;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;

mesh-worker-service/src/main/java/io/functionmesh/compute/util/SourcesUtil.java

@@ -27,7 +27,7 @@
 import io.functionmesh.compute.sources.models.V1alpha1SourceSpecOutputProducerConfCryptoConfig;
 import io.functionmesh.compute.sources.models.V1alpha1SourceSpecPulsar;
 import io.functionmesh.compute.sources.models.V1alpha1SourceSpecResources;
-import io.functionmesh.proxy.models.CustomRuntimeOptions;
+import io.functionmesh.compute.models.CustomRuntimeOptions;
 import io.kubernetes.client.openapi.models.V1ObjectMeta;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;

mesh-worker-service/src/test/java/io/functionmesh/compute/testdata/Generate.java

@@ -19,7 +19,7 @@
 package io.functionmesh.compute.testdata;
 
 import io.functionmesh.compute.util.FunctionsUtil;
-import io.functionmesh.proxy.models.CustomRuntimeOptions;
+import io.functionmesh.compute.models.CustomRuntimeOptions;
 import org.apache.pulsar.common.functions.ConsumerConfig;
 import org.apache.pulsar.common.functions.FunctionConfig;
 import org.apache.pulsar.common.functions.Resources;

mesh-worker-service/src/test/java/io/functionmesh/compute/util/FunctionsUtilTest.java

@@ -25,7 +25,7 @@
 import io.functionmesh.compute.functions.models.V1alpha1FunctionSpecOutput;
 import io.functionmesh.compute.functions.models.V1alpha1FunctionSpecPulsar;
 import io.functionmesh.compute.functions.models.V1alpha1FunctionSpecResources;
-import io.functionmesh.proxy.models.CustomRuntimeOptions;
+import io.functionmesh.compute.models.CustomRuntimeOptions;
 import io.kubernetes.client.openapi.models.V1ObjectMeta;
 import org.apache.pulsar.common.functions.ConsumerConfig;
 import org.apache.pulsar.common.functions.FunctionConfig;