messagelayer

Documentation

Index

• Constants
• func BuildResource(nodeID, namespace, resourceType, resourceID string) (resource string, err error)
• func BuildResourceForDevice(nodeID, resourceType, resourceID string) (resource string, err error)
• func BuildResourceForRouter(resourceType, resourceID string) (string, error)
• func GetDeviceID(resource string) (string, error)
• func GetNamespace(msg model.Message) (string, error)
• func GetNodeID(msg model.Message) (string, error)
• func GetResourceName(msg model.Message) (string, error)
• func GetResourceType(msg model.Message) (string, error)
• func GetResourceTypeForDevice(resource string) (string, error)
• type ContextMessageLayer
  • func (cml *ContextMessageLayer) Receive() (model.Message, error)
  • func (cml *ContextMessageLayer) Response(message model.Message) error
  • func (cml *ContextMessageLayer) Send(message model.Message) error
• type MessageLayer
  • func DeviceControllerMessageLayer() MessageLayer
  • func DynamicControllerMessageLayer() MessageLayer
  • func EdgeControllerMessageLayer() MessageLayer
  • func PolicyControllerMessageLayer() MessageLayer
  • func TaskManagerMessageLayer() MessageLayer

Constants

const (
	ResourceNode = "node"

	ResourceNodeIDIndex       = 1
	ResourceNamespaceIndex    = 2
	ResourceResourceTypeIndex = 3
	ResourceResourceNameIndex = 4

	ResourceDeviceIndex          = 2
	ResourceDeviceNamespaceIndex = 3

	ResourceDevice               = "device"
	ResourceTypeTwinEdgeUpdated  = "twin/edge_updated"
	ResourceTypeMembershipDetail = "membership/detail"
)

Functions

func BuildResource

func BuildResource(nodeID, namespace, resourceType, resourceID string) (resource string, err error)

BuildResource return a string as "beehive/pkg/core/model".Message.Router.Resource

func BuildResourceForDevice

func BuildResourceForDevice(nodeID, resourceType, resourceID string) (resource string, err error)

BuildResourceForDevice return a string as "beehive/pkg/core/model".Message.Router.Resource

func BuildResourceForRouter

func BuildResourceForRouter(resourceType, resourceID string) (string, error)

BuildResourceForRouter return a string as "beehive/pkg/core/model".Message.Router.Resource

func GetDeviceID

func GetDeviceID(resource string) (string, error)

GetDeviceID returns the ID of the device,resource's format:$hw/events/device/{namespace}/{deviceName}

func GetNamespace

func GetNamespace(msg model.Message) (string, error)

GetNamespace from "beehive/pkg/core/model".Model.Router.Resource

func GetNodeID

func GetNodeID(msg model.Message) (string, error)

GetNodeID from "beehive/pkg/core/model".Message.Router.Resource

func GetResourceName

func GetResourceName(msg model.Message) (string, error)

GetResourceName from "beehive/pkg/core/model".Model.Router.Resource

func GetResourceType

func GetResourceType(msg model.Message) (string, error)

GetResourceType from "beehive/pkg/core/model".Model.Router.Resource

func GetResourceTypeForDevice

func GetResourceTypeForDevice(resource string) (string, error)

GetResourceType returns the resourceType of message received from edge

Types

type ContextMessageLayer

type ContextMessageLayer struct {
	// SendModuleName indicates which module will send message to
	SendModuleName string
	// SendRouterModuleName indicates which module will send router message to
	SendRouterModuleName string
	// ReceiveModuleName indicates which module will receive message from
	ReceiveModuleName string
	// ResponseModuleName indicates which module will response message to
	ResponseModuleName string
}

ContextMessageLayer build on context

func (*ContextMessageLayer) Receive

func (cml *ContextMessageLayer) Receive() (model.Message, error)

Receive message

func (*ContextMessageLayer) Response

func (cml *ContextMessageLayer) Response(message model.Message) error

Response message

func (*ContextMessageLayer) Send

func (cml *ContextMessageLayer) Send(message model.Message) error

Send message

type MessageLayer

type MessageLayer interface {
	Send(message model.Message) error
	Receive() (model.Message, error)
	Response(message model.Message) error
}

MessageLayer define all functions that message layer must implement

func DeviceControllerMessageLayer

func DeviceControllerMessageLayer() MessageLayer

func DynamicControllerMessageLayer

func DynamicControllerMessageLayer() MessageLayer

func EdgeControllerMessageLayer

func EdgeControllerMessageLayer() MessageLayer

func PolicyControllerMessageLayer

func PolicyControllerMessageLayer() MessageLayer

func TaskManagerMessageLayer

func TaskManagerMessageLayer() MessageLayer