broker

Documentation

Index

• type RabbitMQ
  • func NewRabbitMQ(logger *zap.SugaredLogger) *RabbitMQ
  • func (r *RabbitMQ) Publish(routingKey string, msg interface{}) error
• type SiteRequestEvent
• type SiteResponseEvent

Types

type RabbitMQ

type RabbitMQ struct {
	Delivery <-chan amqp.Delivery
	Channel  *amqp.Channel
	// contains filtered or unexported fields
}

func NewRabbitMQ

func NewRabbitMQ(logger *zap.SugaredLogger) *RabbitMQ

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(routingKey string, msg interface{}) error

TODO consider use another exachange, will it affect performance? - DONE but check performance

type SiteRequestEvent

type SiteRequestEvent struct {
	Url string `json:"url"`
}

type SiteResponseEvent

type SiteResponseEvent struct {
	ParentUrl  string   `json:"parentUrl"`
	Categories []string `json:"categories"`
	Articles   []string `json:"articles"`
}