messagelayer

Documentation

Index

• func BuildResource(nodeID, resourceType, resourceID string) (resource string, err error)
• func GetDeviceID(resource string) (string, error)
• func GetNodeID(msg model.Message) (string, error)
• func GetResourceType(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 NewContextMessageLayer() MessageLayer

Functions

func BuildResource

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

BuildResource 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

func GetNodeID

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

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

func GetResourceType

func GetResourceType(resource string) (string, error)

GetResourceType returns the resourceType of message received from edge

Types

type ContextMessageLayer

type ContextMessageLayer struct {
	SendModuleName     string
	ReceiveModuleName  string
	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 NewContextMessageLayer

func NewContextMessageLayer() MessageLayer

NewContextMessageLayer create a ContextMessageLayer