bus

package

v1.0.0 Latest Latest Go to latest Published: Jun 16, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New() *Bus

func (b *Bus) Publish(ctx context.Context, topic string, message any) error

func (b *Bus) Subscribe(topic string, buffer int) Subscription

type Envelope struct {
	Topic     string
	Message   any
	Timestamp time.Time
}

type Subscription interface {
	C() <-chan Envelope
	Close() error
}