go-zero/core/queue/messagequeue.go

package queue

type MessageQueue interface {
	Start()
	Stop()
}