Documentation
¶
Overview ¶
Package clickhousecollectnode 提供将一次运行 trace 导出到 ClickHouse 的 collector 节点注册逻辑。
Index ¶
Constants ¶
View Source
const NodeType = "trace.collect.clickhouse"
Variables ¶
View Source
var ( ErrEndpointRequired = errors.New("clickhouse collector endpoint is required") ErrDatabaseRequired = errors.New("clickhouse collector database is required") )
Functions ¶
func Definition ¶
func Definition(client *http.Client) node.Definition
Definition 返回 ClickHouse Collector 的完整注册定义。
Types ¶
type Config ¶
type Config struct {
Endpoint string `json:"endpoint"`
Database string `json:"database"`
Username string `json:"username"`
Password string `json:"password"`
Table string `json:"table"`
TimeoutMs int `json:"timeoutMs"`
}
Config 描述一个 workflow 节点实例要写入的 ClickHouse 目标。
func DefaultConfig ¶
func DefaultConfig() *Config
Source Files
Click to show internal directories.
Click to hide internal directories.