bus

Documentation

Index

• type DefaultEventBus
  • func (d *DefaultEventBus) Publish(ctx context.Context, event Event) error
  • func (d *DefaultEventBus) Subscribe(fn HandlerFunc)
• type Event
• type EventBus
  • func New() EventBus
• type HandlerFunc
• type ProjectCreatedEvent

Types

type DefaultEventBus

type DefaultEventBus struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*DefaultEventBus) Publish

func (d *DefaultEventBus) Publish(ctx context.Context, event Event) error

func (*DefaultEventBus) Subscribe

func (d *DefaultEventBus) Subscribe(fn HandlerFunc)

type Event

type Event any

Event defines a event interface.

type EventBus

type EventBus interface {
	Subscribe(fn HandlerFunc)
	Publish(ctx context.Context, event Event) error
}

EventBus type defines the bus interface structure.

func New

func New() EventBus

type HandlerFunc

type HandlerFunc any

HandlerFunc defines a handler function interface.

type ProjectCreatedEvent

type ProjectCreatedEvent struct {
	ProjectID   int32
	ProjectName string
}