Documentation ¶
Index ¶
- Constants
- type Extension
- type Master
- type MessageQueue
- func (mq *MessageQueue) RegisterDataHandler(t string, dh types.MQDataHandler)
- func (mq *MessageQueue) Run()
- func (mq *MessageQueue) SendMessage(p interface{}, pt string) (string, error)
- func (mq *MessageQueue) SendMessageAwaitingResponse(p interface{}, pt string, rh func(interface{}, string), toh func()) (string, error)
- func (mq *MessageQueue) SendMessageResponse(p interface{}, pt string, id string)
- func (mq *MessageQueue) SetDataHandler(dh types.MQDataHandler)
- func (mq *MessageQueue) Stop()
- func (mq *MessageQueue) UnregisterDataHandler(t string)
Constants ¶
View Source
const TIMEOUT = 1 * time.Minute
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Extension ¶
type Extension struct {
// contains filtered or unexported fields
}
func NewExtension ¶
func NewExtension() *Extension
func (*Extension) ConnectToMaster ¶
func (e *Extension) ConnectToMaster(m interfaces.Master)
func (*Extension) GetMessageQueue ¶
func (e *Extension) GetMessageQueue() *MessageQueue
type Master ¶
type Master struct {
// contains filtered or unexported fields
}
func (*Master) GetDataHandler ¶
func (m *Master) GetDataHandler() etypes.MessageHandler
func (*Master) GetErrorHandler ¶
func (m *Master) GetErrorHandler() etypes.ErrorHandler
func (*Master) GetMessageQueue ¶
func (m *Master) GetMessageQueue() *MessageQueue
func (*Master) SetDataHandler ¶
func (m *Master) SetDataHandler(dh etypes.MessageHandler)
func (*Master) SetErrorHandler ¶
func (m *Master) SetErrorHandler(eh etypes.ErrorHandler)
type MessageQueue ¶
type MessageQueue struct {
// contains filtered or unexported fields
}
func NewMessageQueue ¶
func NewMessageQueue() *MessageQueue
func (*MessageQueue) RegisterDataHandler ¶
func (mq *MessageQueue) RegisterDataHandler(t string, dh types.MQDataHandler)
func (*MessageQueue) Run ¶
func (mq *MessageQueue) Run()
func (*MessageQueue) SendMessage ¶
func (mq *MessageQueue) SendMessage(p interface{}, pt string) (string, error)
func (*MessageQueue) SendMessageAwaitingResponse ¶
func (mq *MessageQueue) SendMessageAwaitingResponse(p interface{}, pt string, rh func(interface{}, string), toh func()) (string, error)
func (*MessageQueue) SendMessageResponse ¶
func (mq *MessageQueue) SendMessageResponse(p interface{}, pt string, id string)
func (*MessageQueue) SetDataHandler ¶
func (mq *MessageQueue) SetDataHandler(dh types.MQDataHandler)
func (*MessageQueue) Stop ¶
func (mq *MessageQueue) Stop()
func (*MessageQueue) UnregisterDataHandler ¶
func (mq *MessageQueue) UnregisterDataHandler(t string)
Click to show internal directories.
Click to hide internal directories.