This is an automated email from the ASF dual-hosted git repository.
xiatian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from fe3d56b11 [ISSUE #5105] Fix the retry mechanism of the
HttpSinkConnector (#5106)
add 98fbf6207 [ISSUE #5108] Abstracting and transforming
EventMeshFunction, and implementing FunctionRuntime. (#5109)
No new revisions were added by this update.
Summary of changes:
.../build.gradle | 0
.../eventmesh-function-api}/build.gradle | 0
.../api/AbstractEventMeshFunctionChain.java | 76 ++++
.../eventmesh/function/api/EventMeshFunction.java | 43 ++
.../eventmesh-function-filter}/build.gradle | 4 +-
.../eventmesh/function}/filter/PatternEntry.java | 4 +-
.../filter/condition/AnythingButCondition.java | 2 +-
.../function}/filter/condition/Condition.java | 2 +-
.../filter/condition/ConditionsBuilder.java | 2 +-
.../filter/condition/ExistsCondition.java | 2 +-
.../filter/condition/NumericCondition.java | 2 +-
.../filter/condition/PrefixCondition.java | 2 +-
.../filter/condition/SpecifiedCondition.java | 2 +-
.../filter/condition/SuffixCondition.java | 2 +-
.../function}/filter/pattern/Pattern.java | 25 +-
.../filter/patternbuild/PatternBuilder.java | 36 +-
.../eventmesh/function}/filter/PatternTest.java | 27 +-
.../eventmesh-function-transformer}/build.gradle | 1 +
.../function}/transformer/ConstantTransformer.java | 2 +-
.../function}/transformer/JsonPathParser.java | 15 +-
.../function}/transformer/OriginalTransformer.java | 3 +-
.../eventmesh/function}/transformer/Template.java | 2 +-
.../function}/transformer/TemplateTransformer.java | 2 +-
.../function}/transformer/TransformException.java | 2 +-
.../function}/transformer/Transformer.java | 16 +-
.../function}/transformer/TransformerBuilder.java | 22 +-
.../function}/transformer/TransformerParam.java | 2 +-
.../function}/transformer/TransformerType.java | 2 +-
.../eventmesh/function}/transformer/Variable.java | 2 +-
.../function}/transformer/TransformTest.java | 20 +-
eventmesh-runtime-v2/build.gradle | 3 +
.../runtime/function/FunctionRuntime.java | 465 +++++++++++++++++++++
.../runtime/function/FunctionRuntimeConfig.java | 35 ++
.../runtime/function/FunctionRuntimeFactory.java | 2 +-
...tory.java => StringEventMeshFunctionChain.java} | 79 ++--
.../src/main/resources/function.yaml | 4 +-
eventmesh-runtime/build.gradle | 5 +-
.../eventmesh/runtime/boot/FilterEngine.java | 4 +-
.../eventmesh/runtime/boot/TransformerEngine.java | 6 +-
.../http/processor/SendAsyncEventProcessor.java | 4 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 4 +-
settings.gradle | 7 +-
42 files changed, 832 insertions(+), 108 deletions(-)
copy {eventmesh-meta => eventmesh-function}/build.gradle (100%)
copy {eventmesh-meta =>
eventmesh-function/eventmesh-function-api}/build.gradle (100%)
create mode 100644
eventmesh-function/eventmesh-function-api/src/main/java/org/apache/eventmesh/function/api/AbstractEventMeshFunctionChain.java
create mode 100644
eventmesh-function/eventmesh-function-api/src/main/java/org/apache/eventmesh/function/api/EventMeshFunction.java
rename {eventmesh-transformer =>
eventmesh-function/eventmesh-function-filter}/build.gradle (92%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/PatternEntry.java
(94%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/AnythingButCondition.java
(97%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/Condition.java
(94%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/ConditionsBuilder.java
(97%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/ExistsCondition.java
(95%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/NumericCondition.java
(97%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/PrefixCondition.java
(95%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/SpecifiedCondition.java
(95%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/condition/SuffixCondition.java
(95%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/pattern/Pattern.java
(75%)
rename {eventmesh-filter/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function}/filter/patternbuild/PatternBuilder.java
(85%)
rename {eventmesh-filter/src/test/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-filter/src/test/java/org/apache/eventmesh/function}/filter/PatternTest.java
(82%)
rename {eventmesh-filter =>
eventmesh-function/eventmesh-function-transformer}/build.gradle (92%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/ConstantTransformer.java
(95%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/JsonPathParser.java
(85%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/OriginalTransformer.java
(94%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/Template.java
(96%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/TemplateTransformer.java
(96%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/TransformException.java
(95%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/Transformer.java
(68%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/TransformerBuilder.java
(69%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/TransformerParam.java
(97%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/TransformerType.java
(97%)
rename {eventmesh-transformer/src/main/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/main/java/org/apache/eventmesh/function}/transformer/Variable.java
(96%)
rename {eventmesh-transformer/src/test/java/org/apache/eventmesh =>
eventmesh-function/eventmesh-function-transformer/src/test/java/org/apache/eventmesh/function}/transformer/TransformTest.java
(88%)
copy
eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/{FunctionRuntimeFactory.java
=> StringEventMeshFunctionChain.java} (61%)
copy
eventmesh-storage-plugin/eventmesh-storage-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
=> eventmesh-runtime-v2/src/main/resources/function.yaml (88%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
