ship

Documentation

Index

• Constants
• func ReadSkis() ([]string, []string)
• func WriteSkis(newSkis []string, newDevices []string)
• type CloseHandler
• type CmiMessage
• type ConnectionManager
• type ConnectionManagerSpine
• type DataValue
• type HeaderType
• type Message
• type Request
• type SMEInstance
  • 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
  • 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()

Constants

const CMI_TIMEOUT = 10

Functions

func ReadSkis

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

func WriteSkis

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

Types

type CloseHandler

type CloseHandler func(*SMEInstance)

type CmiMessage

type CmiMessage struct {
	MessageType  int `json:"MessageType"`
	MessageValue int `json:"MessageValue"`
}

type ConnectionManager

type ConnectionManager func(string, *websocket.Conn)

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 Message

type Message struct {
	MessageType  int `xml:"MessageType"`
	MessageValue DataValue
}

type Request

type Request struct {
	Path string
	Id   string
	Ski  string
}

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 NewShipNode(hostname string, IsGateway bool, certName string, devId string, brand string, devType string) *ShipNode

func (*ShipNode) BrowseDns

func (shipNode *ShipNode) BrowseDns()

func (*ShipNode) Connect

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

func (*ShipNode) RegisterDns

func (shipNode *ShipNode) RegisterDns()

func (*ShipNode) Start

func (shipNode *ShipNode) Start()

func (*ShipNode) StartServer

func (shipNode *ShipNode) StartServer()