Versions in this module Expand all Collapse all v0 v0.9.0 Oct 19, 2020 Changes in this version + const MetricsSubsystem + type Event queue.Item + type Metrics struct + ErrorsHandled metrics.Counter + ErrorsIn metrics.Counter + ErrorsOut metrics.Counter + ErrorsSent metrics.Counter + ErrorsShed metrics.Counter + EventsHandled metrics.Counter + EventsIn metrics.Counter + EventsOut metrics.Counter + EventsSent metrics.Counter + EventsShed metrics.Counter + func NopMetrics() *Metrics + func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics + type Reactor struct + func NewReactor(bufferSize int) *Reactor + func (r *Reactor) AddPeer() + func (r *Reactor) Receive(event Event) + func (r *Reactor) Start() + func (r *Reactor) Stop() + type Routine struct