Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CoAPServerThread ¶
func CoAPServerThread(c *CoAP)
func SetRxChannel ¶
func SetRxChannel(rxChannel chan RxChannelData)
func StompReceiveThread ¶
func StompReceiveThread(s *Stomp, rxChannel chan RxChannelData)
Types ¶
type AgentCoap ¶
type AgentStomp ¶
type AgentStomp struct { Conn *stompngo.Connection DestQueue string MsgCnt uint64 }
func (AgentStomp) GetMsgCnt ¶
func (s AgentStomp) GetMsgCnt() uint64
func (AgentStomp) IncMsgCnt ¶
func (s AgentStomp) IncMsgCnt()
func (AgentStomp) SendMsg ¶
func (s AgentStomp) SendMsg(msg []byte) error
type CoAP ¶
func CoAPServerInit ¶
type RxChannelData ¶
type Stomp ¶
type Stomp struct { Conn *stompngo.Connection RxChannel <-chan stompngo.MessageData }
Click to show internal directories.
Click to hide internal directories.