fimp

Documentation

Index

• func NewNode(flowOpCtx *model.FlowOperationalContext, meta model.MetaNode, ...) model.Node
• type Node
  • func (node *Node) LoadNodeConfig() error
  • func (node *Node) OnInput(msg *model.Message) ([]model.NodeID, error)
  • func (node *Node) WaitForEvent(responseChannel chan model.ReactorEvent)
• type NodeConfig

Functions

func NewNode

func NewNode(flowOpCtx *model.FlowOperationalContext, meta model.MetaNode, ctx *model.Context) model.Node

Types

type Node

type Node struct {
	base.BaseNode
	// contains filtered or unexported fields
}

func (*Node) LoadNodeConfig

func (node *Node) LoadNodeConfig() error

func (*Node) OnInput

func (node *Node) OnInput(msg *model.Message) ([]model.NodeID, error)

func (*Node) WaitForEvent

func (node *Node) WaitForEvent(responseChannel chan model.ReactorEvent)

type NodeConfig

type NodeConfig struct {
	DefaultValue             model.Variable
	VariableName             string
	VariableType             string
	IsVariableGlobal         bool
	Props                    fimpgo.Props
	RegisterAsVirtualService bool
	VirtualServiceGroup      string
	VirtualServiceProps      map[string]interface{} // mostly used to announce supported features of the service , for instance supported modes , states , setpoints , etc...
	ResponseToTopic          string                 // in request-response communication requester can set topic to which server will send response
	IsResponseToReq          bool                   // Indicates that the action is response to request and corid field should be set to the same value as request uuid
}