eventbus

Documentation

Overview

Package eventbus introduces a simple in-memory event bus, in real life scenario, this would need a proper implementation

Index

• type EventBus
  • func NewEventBus(bufferSize int) *EventBus
  • func (e *EventBus) Close()
  • func (e *EventBus) Publish(eventType string, data interface{})
  • func (e *EventBus) Run()
  • func (e *EventBus) Running()
  • func (e *EventBus) Subscribe(eventType string, handler EventHandler)
• type EventHandler
• type NoOpPublisher
  • func (n *NoOpPublisher) Publish(eventType string, data interface{})
• type Publisher

Types

type EventBus

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

func NewEventBus

func NewEventBus(bufferSize int) *EventBus

func (*EventBus) Close

func (e *EventBus) Close()

func (*EventBus) Publish

func (e *EventBus) Publish(eventType string, data interface{})

func (*EventBus) Run

func (e *EventBus) Run()

func (*EventBus) Running

func (e *EventBus) Running()

func (*EventBus) Subscribe

func (e *EventBus) Subscribe(eventType string, handler EventHandler)

type EventHandler

type EventHandler func(data interface{})

type NoOpPublisher

type NoOpPublisher struct{}

func (*NoOpPublisher) Publish

func (n *NoOpPublisher) Publish(eventType string, data interface{})

type Publisher

type Publisher interface {
	Publish(eventType string, data interface{})
}