Versions in this module Expand all Collapse all v0 v0.1.0 Jul 1, 2026 Changes in this version + const DefaultSubscriberBuffer + const KindDeviceConnected + const KindDeviceDisconnected + const KindIncomingData + type Bus struct + func New(reg prometheus.Registerer) *Bus + func (b *Bus) Close() + func (b *Bus) Publish(ev Event) + func (b *Bus) Subscribe(realm string, f Filter, buffer int) (<-chan Event, func()) + func (b *Bus) Subscribers() int + type Event struct + DeviceID string + Interface string + Kind string + Path string + Realm string + Timestamp time.Time + Value any + type Filter struct + DeviceID string + Interface string
Go to main page