ship

Jun 2, 2022

Changes in this version

+ const CMI_TIMEOUT

+ func ReadSkis() ([]string, []string)

+ func WriteSkis(newSkis []string, newDevices []string)

+ type CloseHandler func(*SMEInstance)

+ type CmiMessage struct

+ MessageType int

+ MessageValue int

+ type ConnectionManager func(string, *websocket.Conn)

+ type ConnectionManagerSpine func(*SMEInstance, string)

+ type DataValue struct

+ Header HeaderType

+ Payload resources.DatagramType

+ type HeaderType struct

+ ProtocollId string

+ type Message struct

+ MessageType int

+ MessageValue DataValue

+ type Request struct

+ Id string

+ Path string

+ Ski string

+ type SMEInstance struct

+ Connection *websocket.Conn

+ Ski string

+ func (SME *SMEInstance) Recieve(handleFunc dataHandler)

+ func (SME *SMEInstance) RecieveOnce(handleFunc handler)

+ func (SME *SMEInstance) RecieveTimeout(seconds int) []byte

+ func (SME *SMEInstance) Send(payload resources.DatagramType)

+ func (SME *SMEInstance) StartCMI()

+ type ShipNode struct

+ CertName string

+ IsGateway bool

+ Requests []*Request

+ SME []*SMEInstance

+ SpineCloseHandler CloseHandler

+ SpineConnectionNotify ConnectionManagerSpine

+ func NewShipNode(hostname string, IsGateway bool, certName string, devId string, brand string, ...) *ShipNode

+ func (shipNode *ShipNode) BrowseDns()

+ func (shipNode *ShipNode) Connect(service string, ski string)

+ func (shipNode *ShipNode) RegisterDns()

+ func (shipNode *ShipNode) Start()

+ func (shipNode *ShipNode) StartServer()