event

Documentation

Index

• type Consumer
  • func NewConsumer(conn *amqp.Connection) (Consumer, error)
  • func (consumer *Consumer) Listen(topics []string) error
• type Emitter
  • func NewEventEmitter(conn *amqp.Connection) (Emitter, error)
  • func (e *Emitter) Push(event string, severity string) error
• type Payload

Types

type Consumer

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

func NewConsumer

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

func (*Consumer) Listen

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

type Emitter

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

func NewEventEmitter

func NewEventEmitter(conn *amqp.Connection) (Emitter, error)

func (*Emitter) Push

func (e *Emitter) Push(event string, severity string) error

type Payload

type Payload struct {
	Name string `json:"name"`
	Data string `json:"data"`
}