Documentation
¶
Index ¶
- func NewReceiveNode(flowOpCtx *model.FlowOperationalContext, meta model.MetaNode, ...) model.Node
- func NewTriggerNode(flowOpCtx *model.FlowOperationalContext, meta model.MetaNode, ...) model.Node
- type ReceiveConfig
- type ReceiveNode
- type TriggerConfig
- type TriggerNode
- func (node *TriggerNode) Cleanup() error
- func (node *TriggerNode) Init() error
- func (node *TriggerNode) LoadNodeConfig() error
- func (node *TriggerNode) LookupAddressToAlias(address string)
- func (node *TriggerNode) OnInput(msg *model.Message) ([]model.NodeID, error)
- func (node *TriggerNode) WaitForEvent(nodeEventStream chan model.ReactorEvent)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewReceiveNode ¶
func NewTriggerNode ¶
Types ¶
type ReceiveConfig ¶
type ReceiveNode ¶
ReceiveNode
func (*ReceiveNode) Cleanup ¶
func (node *ReceiveNode) Cleanup() error
func (*ReceiveNode) Init ¶
func (node *ReceiveNode) Init() error
func (*ReceiveNode) LoadNodeConfig ¶
func (node *ReceiveNode) LoadNodeConfig() error
func (*ReceiveNode) WaitForEvent ¶
func (node *ReceiveNode) WaitForEvent(nodeEventStream chan model.ReactorEvent)
type TriggerConfig ¶
type TriggerConfig struct {
Timeout int64 // in seconds
ValueFilter model.Variable
ValueJPath string // JPath path which is used to extract value from trigger message
ValueJPathResultType string // Type of extracted variable
InputVariableType string
IsValueFilterEnabled bool
RegisterAsVirtualService bool // if true - the node will be exposed as service in inclusion report
LookupServiceNameAndLocation bool
VirtualServiceGroup string // is used as service group in inclusion report
VirtualServiceProps map[string]interface{} // mostly used to announce supported features of the service , for instance supported modes , states , setpoints , etc...
}
type TriggerNode ¶
func (*TriggerNode) Cleanup ¶
func (node *TriggerNode) Cleanup() error
func (*TriggerNode) Init ¶
func (node *TriggerNode) Init() error
func (*TriggerNode) LoadNodeConfig ¶
func (node *TriggerNode) LoadNodeConfig() error
func (*TriggerNode) LookupAddressToAlias ¶
func (node *TriggerNode) LookupAddressToAlias(address string)
func (*TriggerNode) WaitForEvent ¶
func (node *TriggerNode) WaitForEvent(nodeEventStream chan model.ReactorEvent)
Click to show internal directories.
Click to hide internal directories.