eventbus

Documentation

Index

• type Event
• type EventBus
  • func GetEventBus() EventBus
  • func Setup(workerPoolSize int) (EventBus, error)
• type EventHandler
• type EventHandlerDecorator
• type EventPublisher
  • func GetEventPublisher() EventPublisher
• type EventSubscriber
  • func GetEventSubscriber() EventSubscriber

Types

type Event

type Event interface{}

Event for event bus

type EventBus

type EventBus interface {
	EventPublisher
	EventSubscriber
	Release()
}

EventBus event bus

func GetEventBus

func GetEventBus() EventBus

GetEventBus returns event bus

func Setup

func Setup(workerPoolSize int) (EventBus, error)

Setup setup event bus

type EventHandler

type EventHandler interface {
	Handle(e Event) error
}

EventHandler event handler

type EventHandlerDecorator

type EventHandlerDecorator func(h EventHandler) EventHandler

EventHandlerDecorator decorator for event handler

type EventPublisher

type EventPublisher interface {
	Publish(events ...Event) error
}

EventPublisher event publisher

func GetEventPublisher

func GetEventPublisher() EventPublisher

GetEventPublisher returns event publisher

type EventSubscriber

type EventSubscriber interface {
	Subscribe(event Event, handlers ...EventHandler)
	SubscribeAll(handlers ...EventHandler)
	Use(decorator EventHandlerDecorator)
}

EventSubscriber event subscriber

func GetEventSubscriber

func GetEventSubscriber() EventSubscriber

GetEventSubscriber returns event subscriber