messagelayer

Documentation

Index

• func BuildResource(nodeID, namespace, resourceType, resourceID string) (resource string, err 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)
• type ContextMessageLayer
  • func NewContextMessageLayer() (*ContextMessageLayer, error)
  • 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 NewMessageLayer() (MessageLayer, error)

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 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

Types

type ContextMessageLayer

type ContextMessageLayer struct {
	SendModuleName     string
	ReceiveModuleName  string
	ResponseModuleName string
	Context            *context.Context
}

ContextMessageLayer build on context

func NewContextMessageLayer

func NewContextMessageLayer() (*ContextMessageLayer, error)

NewContextMessageLayer create a ContextMessageLayer

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 NewMessageLayer

func NewMessageLayer() (MessageLayer, error)

NewMessageLayer by config, currently only context