Versions in this module Expand all Collapse all v0 v0.29.4 Aug 12, 2023 Changes in this version + func BufSize(n int) func(interface{}) error + func Name(name string) func(interface{}) error + func NewBus(opts ...Option) event.Bus + func Stateful(s interface{}) error + type MetricsTracer interface + AddSubscriber func(typ reflect.Type) + EventEmitted func(typ reflect.Type) + RemoveSubscriber func(typ reflect.Type) + SubscriberEventQueued func(name string) + SubscriberQueueFull func(name string, isFull bool) + SubscriberQueueLength func(name string, n int) + func NewMetricsTracer(opts ...MetricsTracerOption) MetricsTracer + type MetricsTracerOption func(*metricsTracerSetting) + func WithRegisterer(reg prometheus.Registerer) MetricsTracerOption + type Option func(*basicBus) + func WithMetricsTracer(metricsTracer MetricsTracer) Option
Go to main page