Versions in this module Expand all Collapse all v1 v1.1.0 Mar 7, 2020 Changes in this version + type Config struct + Callback func() + ErrorCounter *uint64 + Logger *common.Logger + type Mux struct + func New(ctx context.Context, v *viper.Viper, c Config) (*Mux, error) + func (m *Mux) BufferSize() int + func (m *Mux) Close() + func (m *Mux) Push(ev event.Event, f func()) + func (m *Mux) Start() + func (m *Mux) Subscribe(s muxSink) + func (m *Mux) TryFlushQueue()