model

Documentation

Index

• Constants
• func IsFromEdge(msg *model.Message) bool
• func IsNodeStopped(msg *model.Message) bool
• func IsToEdge(msg *model.Message) bool
• func NewResource(resType, resID string, info *HubInfo) string
• type HubInfo

Constants

const (
	ResNode   = "node"
	ResMember = "membership"
	ResTwin   = "twin"
	ResAuth   = "auth_info"
	ResDevice = "device"
)

constants for resource types

const (
	OpGet        = "get"
	OpResult     = "get_result"
	OpList       = "list"
	OpDetail     = "detail"
	OpDelta      = "delta"
	OpDoc        = "document"
	OpUpdate     = "updated"
	OpInsert     = "insert"
	OpDelete     = "deleted"
	OpConnect    = "connected"
	OpDisConnect = "disconnected"
	OpKeepalive  = "keepalive"
)

constants for resource operations

const (
	SrcCloudHub         = "cloudhub"
	SrcEdgeController   = "edgecontroller"
	SrcDeviceController = "devicecontroller"
	SrcManager          = "edgemgr"
)

constants for message source

const (
	ProjectID = "project_id"
	NodeID    = "node_id"
)

constants for identifier information for edge hub

const (
	GpResource = "resource"
)

constants for message group

Functions

func IsFromEdge

func IsFromEdge(msg *model.Message) bool

IsFromEdge judges if the event is sent from edge

func IsNodeStopped

func IsNodeStopped(msg *model.Message) bool

IsNodeStopped indicates if the node is stopped or running

func IsToEdge

func IsToEdge(msg *model.Message) bool

IsToEdge judges if the vent should be sent to edge

func NewResource

func NewResource(resType, resID string, info *HubInfo) string

NewResource constructs a resource field using resource type and ID

Types

type HubInfo

type HubInfo struct {
	ProjectID string
	NodeID    string
}

HubInfo saves identifier information for edge hub