eventbus

README

Simple publish/subscribe asynchronous event bus

Licensing

This program is free software: you can redistribute it and/or modify it under the terms of the Apache license.

Documentation

Index

• Constants
• type EventBus
  • func NewEventBus() *EventBus
  • func (eb *EventBus) Publish(topic string, p int, args ...interface{})
  • func (eb *EventBus) Stop()
  • func (eb *EventBus) Subscribe(topic string, fn interface{})
  • func (eb *EventBus) Unsubscribe(topic string, fn interface{})

Constants

const (
	PriorityLow int = iota
	PriorityHigh
	PriorityCritical
)

The priority levels for event bus messages.

Types

type EventBus

type EventBus struct {
	sync.Mutex
	// contains filtered or unexported fields
}

EventBus handles sending and receiving events.

func NewEventBus

func NewEventBus() *EventBus

NewEventBus initializes and returns an EventBus object.

func (*EventBus) Publish

func (eb *EventBus) Publish(topic string, p int, args ...interface{})

Publish sends req on the channel labeled with name.

func (*EventBus) Stop

func (eb *EventBus) Stop()

Stop prevents any additional requests from being sent.

func (*EventBus) Subscribe

func (eb *EventBus) Subscribe(topic string, fn interface{})

Subscribe registers the callback to be executed for all requests on the topic.

func (*EventBus) Unsubscribe

func (eb *EventBus) Unsubscribe(topic string, fn interface{})

Unsubscribe deregisters the callback from the topic.