Documentation
¶
Index ¶
- Constants
- 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
- type DataGroup
- type DataGroups
- type Envelope
- type EventValue
Constants ¶
View Source
const ( GET = databus.GET SUBSCRIBE = databus.SUBSCRIBE GETPRODUCERS = databus.GETPRODUCERS DELETEPRODUCER = databus.DELETEPRODUCER TERMINATE = databus.TERMINATE )
Variables ¶
This section is empty.
Functions ¶
func NewCommandChan ¶
func NewCommandChan() chan Envelope
func NewDataBusClientWithBus ¶
func NewDataBusClientWithBus(mb messagebus.Messagebus, clientName string) *databus.DataBusClient
func NewDataBusServiceWithBus ¶
func NewDataBusServiceWithBus(mb messagebus.Messagebus) *databus.DataBusService
func NewDataGroupChan ¶
func NewDataProducer ¶
func NewDataProducer() *databus.DataProducer
func NewDataProducers ¶
func NewDataProducers(n int) []*databus.DataProducer
Types ¶
type DataBusService ¶
type DataBusService = databus.DataBusService
type DataGroups ¶
type DataGroups struct {
Mu sync.RWMutex
Groups map[string]map[string]*databus.DataGroup // map from sysid to groupID to groups
}
func NewDataGroupsMap ¶
func NewDataGroupsMap() *DataGroups
func (*DataGroups) AddDataGroup ¶
func (d *DataGroups) AddDataGroup(sysId string, group *databus.DataGroup)
func (*DataGroups) GetDataGroups ¶
func (d *DataGroups) GetDataGroups() map[string]map[string]*databus.DataGroup
type EventValue ¶
type EventValue = databus.EventValue
Source Files
Click to show internal directories.
Click to hide internal directories.