sparrow/pkg/queue/queue_admin.go

package queue

// QueueAdmin 消息队列管理器
type QueueAdmin interface {
	CreateTopicIfNotExists(topic string) error
	Destroy() error
}