events

README

📜 Caesar Events

This repository contains the documentation for the Caesar Events module.

It consists in a very thing layer on top of the Watermill's library, which is a Go library for working efficiently with message queues.

Documentation

Index

• func ListenForEvents(emitter *EventsEmitter)
• type EventsEmitter
  • func NewEventsEmitter() *EventsEmitter
  • func (emitter *EventsEmitter) Emit(topic string, payload []byte)
  • func (emitter *EventsEmitter) On(topic string, handler message.HandlerFunc)
  • func (emitter *EventsEmitter) Run()

Functions

func ListenForEvents

func ListenForEvents(emitter *EventsEmitter)

Types

type EventsEmitter

type EventsEmitter struct {
	*message.Router
	// contains filtered or unexported fields
}

func NewEventsEmitter

func NewEventsEmitter() *EventsEmitter

func (*EventsEmitter) Emit

func (emitter *EventsEmitter) Emit(topic string, payload []byte)

func (*EventsEmitter) On

func (emitter *EventsEmitter) On(topic string, handler message.HandlerFunc)

func (*EventsEmitter) Run

func (emitter *EventsEmitter) Run()