sparrow/pkg/ruleEngine/cluster_service.go

package ruleEngine

import "sparrow/pkg/queue"

type ClusterService interface {
	PushMessageToRuleEngine(info *queue.TopicPartitionInfo, msgId string, msg []byte, callback queue.Callback)
}