Documentation
¶
Index ¶
- Constants
- type Command
- type DataBusClient
- func (d *DataBusClient) DeleteProducer(queue string, service auth.Service)
- func (d *DataBusClient) Get(queue string)
- func (d *DataBusClient) GetGroup(groups chan<- *DataGroup, queue string)
- func (d *DataBusClient) GetProducers(queue string) []DataProducer
- func (d *DataBusClient) GetResponse(queue string) *Response
- func (d *DataBusClient) ReadOneMessage(queue string) string
- func (d *DataBusClient) SendCommand(command Command)
- func (d *DataBusClient) Subscribe(queue string)
- type DataBusService
- func (d *DataBusService) ReceiveCommand(commands chan<- *Command) error
- func (d *DataBusService) SendGroup(group DataGroup)
- func (d *DataBusService) SendGroupToQueue(group DataGroup, queue string)
- func (d *DataBusService) SendMultipleResponses(command string, dataType string, data interface{})
- func (d *DataBusService) SendProducersToQueue(producer []*DataProducer, queue string) error
- func (d *DataBusService) SendResponse(queue string, command string, dataType string, data interface{}) error
- type DataGroup
- type DataProducer
- type DataValue
- type EventValue
- type Response
Constants ¶
View Source
const ( STARTING = "Starting" RUNNING = "Running" TELNOTFOUND = "Telemetry Service Not Found" CONNFAILED = "Connection Failed" )
View Source
const ( GET = "get" SUBSCRIBE = "subscribe" GETPRODUCERS = "getproducers" DELETEPRODUCER = "deleteproducers" TERMINATE = "terminate" )
View Source
const CommandQueue = "/databus"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataBusClient ¶
type DataBusClient struct {
Bus messagebus.Messagebus
}
func (*DataBusClient) DeleteProducer ¶
func (d *DataBusClient) DeleteProducer(queue string, service auth.Service)
func (*DataBusClient) Get ¶
func (d *DataBusClient) Get(queue string)
func (*DataBusClient) GetGroup ¶
func (d *DataBusClient) GetGroup(groups chan<- *DataGroup, queue string)
func (*DataBusClient) GetProducers ¶
func (d *DataBusClient) GetProducers(queue string) []DataProducer
func (*DataBusClient) GetResponse ¶
func (d *DataBusClient) GetResponse(queue string) *Response
func (*DataBusClient) ReadOneMessage ¶
func (d *DataBusClient) ReadOneMessage(queue string) string
func (*DataBusClient) SendCommand ¶
func (d *DataBusClient) SendCommand(command Command)
func (*DataBusClient) Subscribe ¶
func (d *DataBusClient) Subscribe(queue string)
type DataBusService ¶
type DataBusService struct {
Recievers []string
Bus messagebus.Messagebus
}
func (*DataBusService) ReceiveCommand ¶
func (d *DataBusService) ReceiveCommand(commands chan<- *Command) error
func (*DataBusService) SendGroup ¶
func (d *DataBusService) SendGroup(group DataGroup)
func (*DataBusService) SendGroupToQueue ¶
func (d *DataBusService) SendGroupToQueue(group DataGroup, queue string)
func (*DataBusService) SendMultipleResponses ¶
func (d *DataBusService) SendMultipleResponses(command string, dataType string, data interface{})
func (*DataBusService) SendProducersToQueue ¶
func (d *DataBusService) SendProducersToQueue(producer []*DataProducer, queue string) error
func (*DataBusService) SendResponse ¶
func (d *DataBusService) SendResponse(queue string, command string, dataType string, data interface{}) error
type DataProducer ¶
type EventValue ¶
Click to show internal directories.
Click to hide internal directories.