eventbus

Documentation

Index

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

Types

type EventBus

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

EventBus handles sending and receiving events across Amass.

func NewEventBus

func NewEventBus() *EventBus

NewEventBus initializes and returns an EventBus object.

func (*EventBus) Publish

func (eb *EventBus) Publish(topic string, 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 callback to be executed for all requests on the channel.

func (*EventBus) Unsubscribe

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

Unsubscribe deregisters the callback from the channel.