sparrow/pkg/ruleEngine/node.go

package ruleEngine

import "sparrow/pkg/actor"

type Node interface {
	Init(ctx Context, config string) error
	OnMessage(ctx Context, message *Message) error
}
// RuleNodeCtx 节点上下文
type RuleNodeCtx struct {
	TenantId   string    // 租户Id
	chainActor actor.Ref // 规则链 actor
	selfActor  actor.Ref // 当前节点的 actor
	self       *RuleNode // 当前节点
}