model

Documentation

Index

• Constants
• func EventToMessage(event *Event) model.Message
• func NewResource(resType, resID string, info *HubInfo) string
• type Event
  • func MessageToEvent(msg *model.Message) Event
  • func (event *Event) GetContent() string
  • func (event *Event) IsFromEdge() bool
  • func (event *Event) IsNodeStopped() bool
  • func (event *Event) IsToEdge() bool
• type HubInfo
• type UserGroupInfo

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"
	SrcController = "controller"
	SrcManager    = "edgemgr"
)

constants for message source

const (
	GpResource = "resource"
)

constants for message group

Functions

func EventToMessage

func EventToMessage(event *Event) model.Message

EventToMessage converts an event to a model message

func NewResource

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

NewResource constructs a resource field using resource type and ID

Types

type Event

type Event struct {
	Group     string        `json:"msg_group"`
	Source    string        `json:"source"`
	UserGroup UserGroupInfo `json:"user_group"`
	ID        string        `json:"msg_id"`
	ParentID  string        `json:"parent_msg_id"`
	Timestamp int64         `json:"timestamp"`
	Content   interface{}   `json:"content"`
}

Event represents message communicated between cloud hub and edge hub

func MessageToEvent

func MessageToEvent(msg *model.Message) Event

MessageToEvent converts a model message to an event

func (*Event) GetContent

func (event *Event) GetContent() string

GetContent dumps the content to string

func (*Event) IsFromEdge

func (event *Event) IsFromEdge() bool

isFromEdge judges if the event is sent from edge

func (*Event) IsNodeStopped

func (event *Event) IsNodeStopped() bool

IsNodeStopped indicates if the node is stopped or running

func (*Event) IsToEdge

func (event *Event) IsToEdge() bool

IsToEdge judges if the vent should be sent to edge

type HubInfo

type HubInfo struct {
	ProjectID string
	NodeID    string
}

HubInfo saves identifier information for edge hub

type UserGroupInfo

type UserGroupInfo struct {
	Resource  string `json:"resource"`
	Operation string `json:"operation"`
}

UserGroupInfo struct