spine

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL