Versions in this module Expand all Collapse all v1 v1.0.0 Feb 12, 2026 Changes in this version + const DELETEPRODUCER + const GET + const GETPRODUCERS + const SUBSCRIBE + const TERMINATE + func NewCommandChan() chan Envelope + func NewDataBusClientWithBus(mb messagebus.Messagebus, clientName string) *databus.DataBusClient + func NewDataBusServiceWithBus(mb messagebus.Messagebus) *databus.DataBusService + func NewDataGroupChan(n int) chan *databus.DataGroup + func NewDataProducer() *databus.DataProducer + func NewDataProducers(n int) []*databus.DataProducer + type DataBusService = databus.DataBusService + type DataGroup = databus.DataGroup + type DataGroups struct + Groups map[string]map[string]*databus.DataGroup + Mu sync.RWMutex + func NewDataGroupsMap() *DataGroups + func (d *DataGroups) AddDataGroup(sysId string, group *databus.DataGroup) + func (d *DataGroups) GetDataGroups() map[string]map[string]*databus.DataGroup + type Envelope = service.Envelope + type EventValue = databus.EventValue
Go to main page