sparrow/pkg/queue/queue_producer.go

package queue

type RuleEngineQueueProducer interface {
	Init() error
	GetDefaultTopic() string
	Send(info TopicPartitionInfo, msg QueueMessage, callback Callback) error
	Stop() error
}