eventbus

package

v0.4.0 Latest Latest Go to latest Published: Jun 19, 2026 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/GoHyperrr/hyperrr

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RegisterProvider ¶ added in v0.2.0

func RegisterProvider(name string, provider BusProvider)

Types ¶

type BusProvider ¶ added in v0.2.0

type BusProvider = mdk.BusProvider

func GetProvider ¶ added in v0.2.0

func GetProvider(name string) (BusProvider, bool)

type ContextTiedBus ¶ added in v0.2.0

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

type Event ¶

type Event = mdk.Event

Re-export/alias mdk event types

type EventBus ¶

type EventBus = mdk.EventBusCloser

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 (b *InMemBus) Subscribe(namespace, eventType string, handler EventHandler) (func(), error)

Subscribe registers a handler for a specific event type.

func (*InMemBus) Subscribers ¶ added in v0.4.0

func (b *InMemBus) Subscribers() []mdk.SubscriptionInfo

Subscribers returns all active subscriptions on this bus.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL