libs

Documentation

Index

• Variables
• type Consumer
  • func GetConsumerInstance() *Consumer
  • func (t *Consumer) SendMessage(topic string, msg []byte) (err error)
  • func (t *Consumer) StartConsumerMQ(topic string)
• type Producer
  • func GetProducerInstance() *Producer
• type ProducerConsumerServer
  • func (t *ProducerConsumerServer) PublishSaleOrderMessage(in *pb.SaleOrderTemplateMessage, out *pb.SaleOrderTemplateMessage) (err error)

Variables

var (
	MessageInputChannel chan *sarama.ProducerMessage
)

Types

type Consumer

type Consumer struct {
	Client   sarama.Consumer
	TopicMap map[string]interface{} // 消息topic所对应的[]byte解析结构体
}

func GetConsumerInstance

func GetConsumerInstance() *Consumer

func (*Consumer) SendMessage

func (t *Consumer) SendMessage(topic string, msg []byte) (err error)

func (*Consumer) StartConsumerMQ

func (t *Consumer) StartConsumerMQ(topic string)

type Producer

type Producer struct {
	Client sarama.AsyncProducer
}

func GetProducerInstance

func GetProducerInstance() *Producer

type ProducerConsumerServer

type ProducerConsumerServer struct{}

func (*ProducerConsumerServer) PublishSaleOrderMessage

func (t *ProducerConsumerServer) PublishSaleOrderMessage(in *pb.SaleOrderTemplateMessage, out *pb.SaleOrderTemplateMessage) (err error)