event

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2026 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bus 

type Bus interface {
	Publish(event Event)

	Subscribe(handler Handler)
}

type Event 

type Event interface{}

type Handler 

type Handler interface {
	Handle(event Event)
}

type MemoryBus 

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

func NewMemoryBus 

func NewMemoryBus() *MemoryBus

func (*MemoryBus) Publish 

func (b *MemoryBus) Publish(event Event)

func (*MemoryBus) Subscribe 

func (b *MemoryBus) Subscribe(h Handler)

type OrderedMemoryBus 

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

OrderedMemoryBus delivers events in publish order per handler. Each handler owns one buffered queue and one worker goroutine.

func NewOrderedMemoryBus 

func NewOrderedMemoryBus() *OrderedMemoryBus

func (*OrderedMemoryBus) Publish 

func (b *OrderedMemoryBus) Publish(event Event)

func (*OrderedMemoryBus) Subscribe 

func (b *OrderedMemoryBus) Subscribe(h Handler)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.