Versions in this module Expand all Collapse all v1 v1.0.0 Feb 12, 2026 Changes in this version + const CommandQueue + const DATAGROUP + const DELETEPRODUCER + const GET + const GETPRODUCERS + const ReplyPrefix + const SUBSCRIBE + const TERMINATE + type DataBusClient struct + func NewDataBusClient(bus messagebus.Messagebus, clientName string) *DataBusClient + func (d *DataBusClient) DeleteProducer(service auth.Service) error + func (d *DataBusClient) Get(replyQueue string) error + func (d *DataBusClient) GetGroup(groups chan<- *DataGroup, queue string) + func (d *DataBusClient) GetProducers() ([]DataProducer, error) + func (d *DataBusClient) Subscribe(replyQueue string) error + type DataBusService struct + Recievers []string + func NewDataBusService(bus messagebus.Messagebus) *DataBusService + func (d *DataBusService) HandleSubscribeEnvelope(env service.Envelope) + func (d *DataBusService) ReceiveEnvelopes(envelopes chan<- service.Envelope) error + func (d *DataBusService) SendGroup(group DataGroup) + func (d *DataBusService) SendGroupToQueue(group DataGroup, queue string) error + type DataGroup struct + Events []EventValue + FQDN string + FwVer string + HostID string + HostName string + ID string + ImgID string + Label string + Model string + SKU string + Sequence string + System string + Timestamp string + Values []DataValue + type DataProducer struct + Hostname string + LastEvent time.Time + State string + Username string + type DataValue struct + Context string + HostName string + ID string + Label string + System string + Timestamp string + Value string + type EventValue struct + EventId string + EventTimestamp string + EventType string + MemberId string + Message string + MessageArgs []string + MessageId string + MessageSeverity string + OriginOfCondition string
Go to main page