components

package

v0.33.1 Latest Latest Go to latest Published: Jun 27, 2025 License: GPL-3.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flowline-io/flowbot

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var Functions = &FunctionsRegistry{}

Functions ¶

This section is empty.

Types ¶

type CommandNode ¶

type CommandNode struct {
	Config CommandNodeConfiguration
}

func (*CommandNode) Destroy ¶

func (n *CommandNode) Destroy()

func (*CommandNode) Init ¶

func (n *CommandNode) Init(_ ruleTypes.Config, configuration ruleTypes.Configuration) error

func (*CommandNode) New ¶

func (n *CommandNode) New() ruleTypes.Node

func (*CommandNode) OnMsg ¶

func (n *CommandNode) OnMsg(ctx ruleTypes.RuleContext, msg ruleTypes.RuleMsg)

func (*CommandNode) Type ¶

func (n *CommandNode) Type() string

type CommandNodeConfiguration ¶

type CommandNodeConfiguration struct {
	Command string `json:"command" yaml:"command"`
}

type DataNode ¶

type DataNode struct {
	// contains filtered or unexported fields
}

func (*DataNode) Destroy ¶

func (n *DataNode) Destroy()

func (*DataNode) Init ¶

func (n *DataNode) Init(_ ruleTypes.Config, configuration ruleTypes.Configuration) error

func (*DataNode) New ¶

func (n *DataNode) New() ruleTypes.Node

func (*DataNode) OnMsg ¶

func (n *DataNode) OnMsg(ctx ruleTypes.RuleContext, msg ruleTypes.RuleMsg)

func (*DataNode) Type ¶

func (n *DataNode) Type() string

type DefaultUserNode ¶

type DefaultUserNode struct {
	Config DefaultUserNodeConfiguration
}

func (*DefaultUserNode) Destroy ¶

func (n *DefaultUserNode) Destroy()

func (*DefaultUserNode) Init ¶

func (n *DefaultUserNode) Init(_ ruleTypes.Config, configuration ruleTypes.Configuration) error

func (*DefaultUserNode) New ¶

func (n *DefaultUserNode) New() ruleTypes.Node

func (*DefaultUserNode) OnMsg ¶

func (n *DefaultUserNode) OnMsg(ctx ruleTypes.RuleContext, msg ruleTypes.RuleMsg)

func (*DefaultUserNode) Type ¶

func (n *DefaultUserNode) Type() string

type DefaultUserNodeConfiguration ¶

type DefaultUserNodeConfiguration struct {
	Uid string `json:"uid" yaml:"uid"`
}

type FunctionsNode ¶

type FunctionsNode struct {
	Config  FunctionsNodeConfiguration
	HasVars bool
}

func (*FunctionsNode) Destroy ¶

func (x *FunctionsNode) Destroy()

func (*FunctionsNode) Init ¶

func (x *FunctionsNode) Init(_ types.Config, configuration types.Configuration) error

func (*FunctionsNode) New ¶

func (x *FunctionsNode) New() types.Node

func (*FunctionsNode) OnMsg ¶

func (x *FunctionsNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)

func (*FunctionsNode) Type ¶

func (x *FunctionsNode) Type() string

type FunctionsNodeConfiguration ¶

type FunctionsNodeConfiguration struct {
	FunctionName string
	Params       map[string]interface{}
}

type FunctionsRegistry ¶

type FunctionsRegistry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*FunctionsRegistry) Get ¶

func (x *FunctionsRegistry) Get(functionName string) (func(ctx types.RuleContext, msg types.RuleMsg), bool)

func (*FunctionsRegistry) Names ¶

func (x *FunctionsRegistry) Names() []string

func (*FunctionsRegistry) Register ¶

func (x *FunctionsRegistry) Register(functionName string, f func(ctx types.RuleContext, msg types.RuleMsg))

func (*FunctionsRegistry) UnRegister ¶

func (x *FunctionsRegistry) UnRegister(functionName string)

Source Files ¶

View all Source files

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