sparrow/pkg/queue/cluster_service.go

package queue

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