eventbus

README

eventbus

Package eventbus provides event bus interfaces

Download:

go get -u github.com/bradishungry/go-api-learning/pkg/eventbus

---

Package eventbus provides event bus interfaces

Documentation

Overview

Package eventbus provides interfaces along with helper functions

Index

• type EventBus
• type EventHandler

Types

type EventBus

type EventBus interface {
	Publish(ctx context.Context, event *domain.Event) error
	Subscribe(ctx context.Context, eventType string, fn EventHandler) error
	Unsubscribe(ctx context.Context, eventType string, fn EventHandler) error

	// PublishAndAcknowledge blocks and returns grouped error after all handlers are executed
	PublishAndAcknowledge(parentCtx context.Context, event *domain.Event) error
}

EventBus interface event bus is different to command bus by allowing multiple handlers to the same topic

type EventHandler

type EventHandler func(ctx context.Context, event *domain.Event) error

EventHandler function