mq

Documentation

Index

• type Consumer
• type LocalQueue
• type Producer
• type Queue
  • func NewMQ(mqType string) (Queue, error)
• type ThirdConsumer
• type ThirdProducer
• type ThirdQueue

Types

type Consumer

type Consumer interface {
	Consume() (worker.Task, error)
}

type LocalQueue

type LocalQueue interface {
	Producer
	Consumer
}

type Producer

type Producer interface {
	Produce(task worker.Task) error
}

type Queue

type Queue interface {
	LocalQueue
	io.Closer
}

func NewMQ

func NewMQ(mqType string) (Queue, error)

type ThirdConsumer

type ThirdConsumer interface {
	Subscribe(topic, queueName string, fn kafka.MsgCb) error
}

type ThirdProducer

type ThirdProducer interface {
	Publish(topic string, body []byte, reqID string) error
}

type ThirdQueue

type ThirdQueue interface {
	ThirdProducer
	ThirdConsumer
}

ThirdQueue 第三方mq