fimp

package
v0.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewReceiveNode

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

func NewTriggerNode

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

Types

type ReceiveConfig

type ReceiveConfig struct {
	Timeout                  int64 // in seconds
	ValueFilter              model.Variable
	InputVariableType        string
	IsValueFilterEnabled     bool
	RegisterAsVirtualService bool
	VirtualServiceGroup      string
}

type ReceiveNode

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

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

func (node *ReceiveNode) OnInput(msg *model.Message) ([]model.NodeID, 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

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

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

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

func (*TriggerNode) WaitForEvent

func (node *TriggerNode) WaitForEvent(nodeEventStream chan model.ReactorEvent)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL