events

Documentation

Index

• func SubscribeAsync[T Event](b *Bus, sub func(T))
• func SubscribeSync[T Event](b *Bus, sub func(T) error)
• type Bus
  • func NewBus(logger log.Logger) *Bus
  • func (b *Bus) Publish(event Event) error
• type DidCommitBlock
• type DidSaveSnapshot
• type Event
• type FatalError
  • func (e FatalError) Error() string
  • func (e FatalError) Unwrap() error
• type WillChangeGlobals

Functions

func SubscribeAsync

func SubscribeAsync[T Event](b *Bus, sub func(T))

func SubscribeSync

func SubscribeSync[T Event](b *Bus, sub func(T) error)

Types

type Bus

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

func NewBus

func NewBus(logger log.Logger) *Bus

func (*Bus) Publish

func (b *Bus) Publish(event Event) error

type DidCommitBlock

type DidCommitBlock struct {
	Index uint64
	Time  time.Time
	Major uint64
}

type DidSaveSnapshot

type DidSaveSnapshot struct {
	MinorIndex uint64
}

type Event

type Event interface {
	// contains filtered or unexported methods
}

type FatalError

type FatalError struct {
	Err error
}

func (FatalError) Error

func (e FatalError) Error() string

func (FatalError) Unwrap

func (e FatalError) Unwrap() error

type WillChangeGlobals

type WillChangeGlobals struct {
	New, Old *core.GlobalValues
}