spine

Documentation

Index

• type BindSubscribe
  • func (bindSubscribe BindSubscribe) Send(msgClassifier string, payload *resources.PayloadType)
• type BindSubscribeInfo
• type BindSubscribeNotify
• type Notifier
• type SpineConnection
  • func NewSpineConnection(SME *ship.SMEInstance, ownDevice *resources.DeviceModel, ...) *SpineConnection
  • func (conn *SpineConnection) CountBindings(serverAddr resources.FeatureAddressType) int
  • func (conn *SpineConnection) CountSubscriptions(serverAddr resources.FeatureAddressType) int
  • func (conn *SpineConnection) RecieveTimeout(seconds int) (resources.DatagramType, bool)
  • func (conn *SpineConnection) SendXML(header *resources.HeaderType, payload *resources.PayloadType)
  • func (conn *SpineConnection) StartDetailedDiscovery()
  • func (conn *SpineConnection) StartRecieveHandler()
• type SpineNode
  • func NewSpineNode(hostname string, isGateway bool, deviceModel *resources.DeviceModel, ...) *SpineNode
  • func (spineNode *SpineNode) Start()
• type SubscriptionData

Types

type BindSubscribe

type BindSubscribe struct {
	Conn               *SpineConnection
	BindSubscribeEntry *resources.BindSubscribeEntry
}

func (BindSubscribe) Send

func (bindSubscribe BindSubscribe) Send(msgClassifier string, payload *resources.PayloadType)

type BindSubscribeInfo

type BindSubscribeInfo struct {
	BindSubscribe      string
	BindSubscribeEntry *resources.BindSubscribeEntry
}

type BindSubscribeNotify

type BindSubscribeNotify func(string, *SpineConnection, *resources.BindSubscribeEntry)

type Notifier

type Notifier func(resources.DatagramType, SpineConnection)

type SpineConnection

type SpineConnection struct {
	SME        *ship.SMEInstance
	Address    string
	MsgCounter int
	OwnDevice  *resources.DeviceModel

	DiscoveryInformation *resources.NodeManagementDetailedDiscovery

	SubscriptionNofity Notifier
	SubscriptionData   []*SubscriptionData
	// contains filtered or unexported fields
}

func NewSpineConnection

func NewSpineConnection(SME *ship.SMEInstance, ownDevice *resources.DeviceModel, bindSubscribeNotify BindSubscribeNotify, SubscriptionNofity Notifier) *SpineConnection

func (*SpineConnection) CountBindings

func (conn *SpineConnection) CountBindings(serverAddr resources.FeatureAddressType) int

func (*SpineConnection) CountSubscriptions

func (conn *SpineConnection) CountSubscriptions(serverAddr resources.FeatureAddressType) int

func (*SpineConnection) RecieveTimeout

func (conn *SpineConnection) RecieveTimeout(seconds int) (resources.DatagramType, bool)

func (*SpineConnection) SendXML

func (conn *SpineConnection) SendXML(header *resources.HeaderType, payload *resources.PayloadType)

func (*SpineConnection) StartDetailedDiscovery

func (conn *SpineConnection) StartDetailedDiscovery()

func (*SpineConnection) StartRecieveHandler

func (conn *SpineConnection) StartRecieveHandler()

type SpineNode

type SpineNode struct {
	ShipNode           *ship.ShipNode
	Connections        []*SpineConnection
	DeviceStructure    *resources.DeviceModel
	Bindings           []*BindSubscribe
	Subscriptions      []*BindSubscribe
	SubscriptionNofity Notifier
}

func NewSpineNode

func NewSpineNode(hostname string, isGateway bool, deviceModel *resources.DeviceModel, SubscriptionNofity Notifier, certName string, devId string, brand string, devType string) *SpineNode

func (*SpineNode) Start

func (spineNode *SpineNode) Start()

type SubscriptionData

type SubscriptionData struct {
	EntityType     string
	FeatureType    string
	FeatureAddress resources.FeatureAddressType
	FunctionName   string
	CurrentState   string
}