eventbus

Documentation

Index

• func RegisterProvider(name string, provider BusProvider)
• type BusProvider
  • func GetProvider(name string) (BusProvider, bool)
• type ContextTiedBus
• type Event
• type EventBus
• type EventHandler
• type InMemBus
  • func NewInMemBus() *InMemBus
  • func (b *InMemBus) Close() error
  • func (b *InMemBus) Publish(ctx context.Context, event Event) error
  • func (b *InMemBus) SetAsync(async bool)
  • func (b *InMemBus) Subscribe(namespace, eventType string, handler EventHandler) (func(), error)

Functions

func RegisterProvider

func RegisterProvider(name string, provider BusProvider)

Types

type BusProvider

type BusProvider func(url string) (EventBus, error)

func GetProvider

func GetProvider(name string) (BusProvider, bool)

type ContextTiedBus

type ContextTiedBus interface {
	EventBus
	SetContext(ctx context.Context)
}

type Event

type Event = mdk.Event

Re-export/alias mdk event types

type EventBus

type EventBus interface {
	mdk.EventBus
	Close() error
}

type EventHandler

type EventHandler = mdk.EventHandler

type InMemBus

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

InMemBus is a thread-safe in-memory implementation of EventBus.

func NewInMemBus

func NewInMemBus() *InMemBus

NewInMemBus creates a new InMemBus.

func (*InMemBus) Close

func (b *InMemBus) Close() error

Close closes the event bus.

func (*InMemBus) Publish

func (b *InMemBus) Publish(ctx context.Context, event Event) error

Publish sends an event to all registered handlers for the event type.

func (*InMemBus) SetAsync

func (b *InMemBus) SetAsync(async bool)

SetAsync enables or disables asynchronous handler execution.

func (*InMemBus) Subscribe

func (b *InMemBus) Subscribe(namespace, eventType string, handler EventHandler) (func(), error)

Subscribe registers a handler for a specific event type.