sparrow/pkg/ruleEngine/cluster_service.go

package ruleEngine

import (
	"sparrow/pkg/protocol"
	"sparrow/pkg/queue"
)

type ClusterService interface {
	PushMessageToRuleEngine(info *queue.TopicPartitionInfo, msgId string, msg *protocol.Message, callback queue.Callback)
}