bus

type Bus interface {
	AddListener() chan Event
	Publish(Event)
	Run(context.Context)
	History() []HistoricalEvent
	Errors() []HistoricalError
}

type Config struct {
	MaxEvents            int
	MaxErrors            int
	InboundSize          int
	MinimumPriorityLevel int
	EnableDebugLog       bool
	EnableErrorLog       bool
}

type Event interface{}

type HistoricalError struct {
	E  error
	Ts time.Time
}

type HistoricalEvent struct {
	E  Event
	Ts time.Time
}