event

Documentation

Index

• func In(str string, list ...string) bool
• type Consumer
  • func NewConsumer(conn *amqp.Connection, queueName string) (*Consumer, error)
  • func (consumer *Consumer) Listen(topics []string) error
• type Payload

Functions

func In

func In(str string, list ...string) bool

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(conn *amqp.Connection, queueName string) (*Consumer, error)

func (*Consumer) Listen

func (consumer *Consumer) Listen(topics []string) error

type Payload

type Payload struct {
	Topic string         `json:"topic"`
	Data  map[string]any `json:"data"`
}