go-zero/core/queue/consumer.go

package queue

type (
	// A Consumer interface represents a consumer that can consume string messages.
	Consumer interface {
		Consume(string) error
		OnEvent(event interface{})
	}

	// ConsumerFactory defines the factory to generate consumers.
	ConsumerFactory func() (Consumer, error)
)