mysqlcollectnode

package

v0.2.0 Latest Latest Go to latest Published: Aug 26, 2026 License: MIT Imports: 12 Imported by: 0

Details

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

Repository

github.com/EthanScriptOn/FlowLink

Links

Open Source Insights

Documentation ¶

Overview ¶

Package mysqlcollectnode 提供将一次运行 trace 导出到 MySQL 的 collector 节点注册逻辑。

Index ¶

Constants
Variables
func Definition() node.Definition
type Config
- func DefaultConfig() *Config
type Node
- func NewNode() *Node
- func (e *Node) Execute(fc *core.FlowContext, node *core.NodeDefine) (interface{}, error)

Constants ¶

View Source

const NodeType = "trace.collect.mysql"

Variables ¶

View Source

var (
	ErrAddressRequired  = errors.New("mysql collector address is required")
	ErrDatabaseRequired = errors.New("mysql collector database is required")
	ErrUsernameRequired = errors.New("mysql collector username is required")
)

Functions ¶

func Definition ¶

func Definition() node.Definition

Definition 返回 MySQL Collector 的完整注册定义。

Types ¶

type Config ¶

type Config struct {
	Address   string `json:"address"`
	Database  string `json:"database"`
	Username  string `json:"username"`
	Password  string `json:"password"`
	Table     string `json:"table"`
	TimeoutMs int    `json:"timeoutMs"`
}

Config 描述一个 workflow 节点实例要写入的 MySQL 目标。

func DefaultConfig ¶

func DefaultConfig() *Config

type Node ¶

type Node struct{}

Node 在执行时读取当前节点实例配置，不绑定进程级 MySQL 实例。

func NewNode ¶

func NewNode() *Node

func (*Node) Execute ¶

func (e *Node) Execute(fc *core.FlowContext, node *core.NodeDefine) (interface{}, error)

Source Files ¶

View all Source files

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