events

Documentation

Index

• type CallbackPool
  • func (cp *CallbackPool) Add(callback *func(Event))
  • func (cp *CallbackPool) Remove(callback *func(Event))
• type Event
• type EventBus
  • func New() *EventBus
  • func (e *EventBus) Destroy()
  • func (e *EventBus) Off(topic string, callback *func(Event))
  • func (e *EventBus) On(topic string, callback *func(Event))
  • func (e *EventBus) Publish(topic string, data string)
  • func (e *EventBus) PublishJson(topic string, data interface{}) error

Types

type CallbackPool

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

func (*CallbackPool) Add

func (cp *CallbackPool) Add(callback *func(Event))

Pushes a new callback into the array of listeners for the pool.

func (*CallbackPool) Remove

func (cp *CallbackPool) Remove(callback *func(Event))

Removes a callback from the array of registered callbacks if it exists.

type Event

type Event struct {
	Data  string
	Topic string
}

type EventBus

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

func New

func New() *EventBus

func (*EventBus) Destroy

func (e *EventBus) Destroy()

Destroy removes all the event listeners that have been registered for any topic. Also stops the worker pool to close that routine.

func (*EventBus) Off

func (e *EventBus) Off(topic string, callback *func(Event))

Off removes an event listener from the bus.

func (*EventBus) On

func (e *EventBus) On(topic string, callback *func(Event))

On adds a callback function that will be executed each time one of the events using the topic name is called.

func (*EventBus) Publish

func (e *EventBus) Publish(topic string, data string)

Publish data to a given topic.

func (*EventBus) PublishJson

func (e *EventBus) PublishJson(topic string, data interface{}) error

PublishJson publishes a JSON message to a given topic.