bus

Documentation

Index

• func New(cfg *Config) *memoryBus
• func NewLogSink(ch chan Event)
• func SetFlags(fs *pflag.FlagSet, cfg *Config)
• type Bus
• type Config
• type Event
• type HistoricalError
  • func (he HistoricalError) FmtTime() string
  • func (he HistoricalError) Type() string
• type HistoricalEvent
  • func (he HistoricalEvent) FmtTime() string
  • func (he HistoricalEvent) Type() string

Functions

func New

func New(cfg *Config) *memoryBus

func NewLogSink

func NewLogSink(ch chan Event)

func SetFlags

func SetFlags(fs *pflag.FlagSet, cfg *Config)

Types

type Bus

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

type Config

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

type Event

type Event interface{}

type HistoricalError

type HistoricalError struct {
	E  error
	Ts time.Time
}

func (HistoricalError) FmtTime

func (he HistoricalError) FmtTime() string

func (HistoricalError) Type

func (he HistoricalError) Type() string

type HistoricalEvent

type HistoricalEvent struct {
	E  Event
	Ts time.Time
}

func (HistoricalEvent) FmtTime

func (he HistoricalEvent) FmtTime() string

func (HistoricalEvent) Type

func (he HistoricalEvent) Type() string