rulego / rulego Goto Github PK

{
"ruleChain": {
"id":"rule01"
},
"metadata": {
"nodes": [
],
"connections": [
]
}
}
类似这样的空链，初始化没有问题，调用 onMsg 会 panic；既然允许这么初始化，onMsg 是否应该正常工作；或者提供空链的 check 方法。

我现在想要实现服务编排的功能，并发获取不同服务的数据，然后在最后组合数据；

connections 如下：

 "connections": [
      {
        "fromId": "s1",
        "toId": "s2",
        "type": "Success"
      },
      {
        "fromId": "s1",
        "toId": "s3",
        "type": "Success"
      },
      {
        "fromId": "s2",
        "toId": "s4",
        "type": "Success"
      },
      {
        "fromId": "s3",
        "toId": "s4",
        "type": "Success"
      }
    ],

按我的理解s4依赖s2、s3应该等到s2、s3都执行完毕才能执行，但现在的效果是s4执行了多次；

请问我应该如何实现这样的需求

请问rulego如何保证执行流程中断后重启还能断点续执行，是否有持久化的逻辑

是单机版的吗？未来路线图种有集群化发展的考虑吗？

The core feature of RuleGo is componentization, where all business logic is composed of components, and they can be flexibly configured and reused. Currently, RuleGo has built-in some common components, such as message type Switch, JavaScript Switch, JavaScript Filter, JavaScript Transformer, HTTP Push, MQTT Push, Send Email, Log Record and so on.
However, we know that these components are far from meeting the needs of all users, so we hope to have more developers contribute to RuleGo's extension components, making RuleGo's ecosystem more rich and powerful.

If you are interested in RuleGo and want to contribute to its extension components, you can follow these steps:

• Read RuleGo's documentation , and learn about its architecture, features and usage.
• Fork RuleGo's repository , and clone it to your local machine.
• Refer to RuleGo's examples , and write your own extension component, implementing the corresponding interfaces and methods.
• Test your extension component locally, and make sure it works properly and correctly.
• Submit your code and create a pull request, we will review and merge your contribution as soon as possible.
• Give a star to the RuleGo project on GitHub/Gitee, and let more people know about it.

We welcome and appreciate any form of contribution, whether it is code, documentation, suggestion or feedback. We believe that with your support, RuleGo will become a better rule engine and event processing framework. Thank you!

If the component code you submit has no third-party dependencies or is a general-purpose component, please submit it to the built-in components under github.com/rulego/rulego , otherwise submit it to this repository: rulego-components .

What new features do you want RuleGo to add? Please leave a message here.

我们准备做一个流程编排系统，需要记录各节点的流转状态，比如开始结束时间，耗时，输入，输出，日志等，目前可能需要一个Hook（或者类似的机制）在每个节点都执行上面说的相同的动作，我在现有的文档中没有找到类似的说明，请问现在有这样的机制吗？

A concurrent map writes conflict in group_action_node.OnMsg.

https://github.com/rulego/rulego/blob/b4674177a9f186f53db366fb327f853d3a735f6c/components/action/group_action_node.go#L120C2-L132C6

How to ensure dynamic uninstall of plugins using native plugin packages?

没看到python runtime相关示例，目前还不支持吗

场景:
解决方案部，很多会写python，决策相关逻辑通过python实现，这样更利于推广