databus

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
  • func NewDataGroupsMap() *DataGroups
  • func (d *DataGroups) AddDataGroup(sysId string, group *databus.DataGroup)
  • func (d *DataGroups) GetDataGroups() map[string]map[string]*databus.DataGroup
• type Envelope
• type EventValue

Constants

const (
	GET            = databus.GET
	SUBSCRIBE      = databus.SUBSCRIBE
	GETPRODUCERS   = databus.GETPRODUCERS
	DELETEPRODUCER = databus.DELETEPRODUCER
	TERMINATE      = databus.TERMINATE
)

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 NewDataGroupChan(n int) chan *databus.DataGroup

func NewDataProducer

func NewDataProducer() *databus.DataProducer

func NewDataProducers

func NewDataProducers(n int) []*databus.DataProducer

Types

type DataBusService

type DataBusService = databus.DataBusService

type DataGroup

type DataGroup = databus.DataGroup

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 Envelope

type Envelope = service.Envelope

type EventValue

type EventValue = databus.EventValue