diff --git a/pkg/rule_engine/instance.go b/pkg/rule_engine/instance.go index 022c5ba..f5084d4 100644 --- a/pkg/rule_engine/instance.go +++ b/pkg/rule_engine/instance.go @@ -79,7 +79,7 @@ func newInstanceWithManifest(m *manifest.Manifest) (*ruleChainInstance, []error) return r, errs } -// StartRuleChain TODO 是否需要添加context +// StartRuleChain func (c *ruleChainInstance) StartRuleChain(context context.Context, message message.Message) error { if node, found := c.nodes[c.firstRuleNodeId]; found { go node.Handle(message)