Documentation
¶
Index ¶
Constants ¶
View Source
const CMI_TIMEOUT = 10
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CloseHandler ¶
type CloseHandler func(*SMEInstance)
type CmiMessage ¶
type ConnectionManager ¶
type ConnectionManagerSpine ¶
type ConnectionManagerSpine func(*SMEInstance, string)
type DataValue ¶
type DataValue struct {
Header HeaderType `xml:"header"`
Payload resources.DatagramType `xml:"payload"`
}
type HeaderType ¶
type HeaderType struct {
ProtocollId string `xml:"protocollId"`
}
type SMEInstance ¶
type SMEInstance struct {
Connection *websocket.Conn
Ski string
// contains filtered or unexported fields
}
func (*SMEInstance) Recieve ¶
func (SME *SMEInstance) Recieve(handleFunc dataHandler)
func (*SMEInstance) RecieveOnce ¶
func (SME *SMEInstance) RecieveOnce(handleFunc handler)
Use XML format
- Notify SPINE node that connection is active - Recieve and send methods should be available
func (*SMEInstance) RecieveTimeout ¶
func (SME *SMEInstance) RecieveTimeout(seconds int) []byte
func (*SMEInstance) Send ¶
func (SME *SMEInstance) Send(payload resources.DatagramType)
Sends messages in json format
func (*SMEInstance) StartCMI ¶
func (SME *SMEInstance) StartCMI()
type ShipNode ¶
type ShipNode struct {
IsGateway bool
SME []*SMEInstance
Requests []*Request
SpineConnectionNotify ConnectionManagerSpine
SpineCloseHandler CloseHandler
CertName string
// contains filtered or unexported fields
}
func NewShipNode ¶
func (*ShipNode) RegisterDns ¶
func (shipNode *ShipNode) RegisterDns()
func (*ShipNode) StartServer ¶
func (shipNode *ShipNode) StartServer()
Click to show internal directories.
Click to hide internal directories.