eventbus

Documentation

Index

• Constants
• Variables
• type Bus
  • func New(logger interfaces.Logger) *Bus
  • func (b *Bus) Emit(ctx context.Context, eventType string, data any) error
  • func (b *Bus) EmitAsync(ctx context.Context, eventType string, data any)
  • func (b *Bus) EmitEvent(ctx context.Context, event *Event) error
  • func (b *Bus) Shutdown(ctx context.Context) error
  • func (b *Bus) Subscribe(eventType string, handler Handler, opts ...Option) *Subscription
  • func (b *Bus) Unsubscribe(sub *Subscription)
  • func (b *Bus) WaitForShutdown() <-chan struct{}
• type Event
• type Handler
• type Option
  • func WithFilter(f func(*Event) bool) Option
  • func WithPriority(p int) Option
• type Subscription

Constants

const (
	EventMessage   = "message"
	EventCommand   = "command"
	EventRawUpdate = "raw_update"
	EventShutdown  = "shutdown"
	EventStart     = "start"
	EventError     = "error"
)

Variables

var ErrHandlerTimeout = errors.New("eventbus: handler timed out")

ErrHandlerTimeout is returned when a handler exceeds its execution deadline.

Types

type Bus

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

func New

func New(logger interfaces.Logger) *Bus

func (*Bus) Emit

func (b *Bus) Emit(ctx context.Context, eventType string, data any) error

func (*Bus) EmitAsync

func (b *Bus) EmitAsync(ctx context.Context, eventType string, data any)

func (*Bus) EmitEvent

func (b *Bus) EmitEvent(ctx context.Context, event *Event) error

func (*Bus) Shutdown

func (b *Bus) Shutdown(ctx context.Context) error

func (*Bus) Subscribe

func (b *Bus) Subscribe(eventType string, handler Handler, opts ...Option) *Subscription

func (*Bus) Unsubscribe

func (b *Bus) Unsubscribe(sub *Subscription)

func (*Bus) WaitForShutdown

func (b *Bus) WaitForShutdown() <-chan struct{}

type Event

type Event struct {
	Type      string
	Timestamp time.Time
	Data      any
	Context   context.Context
	Metadata  map[string]any
}

type Handler

type Handler func(ctx context.Context, event *Event) error

type Option

type Option func(*Subscription)

func WithFilter

func WithFilter(f func(*Event) bool) Option

func WithPriority

func WithPriority(p int) Option

type Subscription

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