Documentation
¶
Overview ¶
Package agentanalysis 提供 Agent 内置工具所需的「分析节点」能力： 运行节点（run_analysis_node）、生成节点参数（build_analysis_node_params）、 更新节点信息（update_agent_analysis / update_script_analysis）、为已有脚本创建节点（create_script_analysis）， 以及创建命令型节点并可选运行（create_agent_analysis）。
这些实现只依赖 tool 包定义的接口与业务服务，由 container 包在 DI 中装配。
Index ¶
- func DecodeRequestParam(raw string) map[string]any
- func NewAgentAnalysisRunner(analysisRepo interfaces.AnalysisRepository, ...) runtimecontext.AgentAnalysisRunner
- func NewNodeRunner(analysisSvc interfaces.AnalysisService, ...) runtimecontext.AnalysisNodeRunner
- func NewNodeUpdater(analysisSvc interfaces.AnalysisService, workflowSvc interfaces.WorkflowService, ...) runtimecontext.AnalysisNodeUpdater
- func NewParamsBuilder(analysisSvc interfaces.AnalysisService, ...) runtimecontext.AnalysisNodeParamsBuilder
- func NewScriptNodeCreator(workflowSvc interfaces.WorkflowService, ...) runtimecontext.AnalysisNodeCreator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeRequestParam ¶
DecodeRequestParam 把节点上保存的 request_param JSON 文本反解成 map。
节点字段为字符串（types.AnalysisNode.RequestParam）：运行前未传参时用它回退到 「节点已保存的参数」，只读浏览（get_analysis_node）也用它回传结构化参数。 内容为空 / 非法 JSON / 空对象时返回 nil。
func NewAgentAnalysisRunner ¶
func NewAgentAnalysisRunner( analysisRepo interfaces.AnalysisRepository, containerRepo interfaces.ContainerRepository, preparer prepare.NodeRuntimePreparer, nodeRunner runtimecontext.AnalysisNodeRunner, cfg *config.Config, ) runtimecontext.AgentAnalysisRunner
NewAgentAnalysisRunner 构建 create_agent_analysis 工具的执行器。
func NewNodeRunner ¶
func NewNodeRunner( analysisSvc interfaces.AnalysisService, nodeOrchestrator interfaces.NodeOrchestrator, workflowSvc interfaces.WorkflowService, analysisRepo interfaces.AnalysisRepository, dataSvc interfaces.DataService, preparer prepare.NodeRuntimePreparer, router *dagruntime.EventRouter, cfg *config.Config, ) runtimecontext.AnalysisNodeRunner
NewNodeRunner 构建分析节点运行器并注入内置工具体系。
func NewNodeUpdater ¶
func NewNodeUpdater( analysisSvc interfaces.AnalysisService, workflowSvc interfaces.WorkflowService, dataSvc interfaces.DataService, containerRepo interfaces.ContainerRepository, preparer prepare.NodeRuntimePreparer, ) runtimecontext.AnalysisNodeUpdater
NewNodeUpdater 构建「更新分析节点」执行器并注入内置工具体系。
func NewParamsBuilder ¶
func NewParamsBuilder( analysisSvc interfaces.AnalysisService, analysisRepo interfaces.AnalysisRepository, workflowSvc interfaces.WorkflowService, dataSvc interfaces.DataService, preparer prepare.NodeRuntimePreparer, cfg *config.Config, ) runtimecontext.AnalysisNodeParamsBuilder
NewParamsBuilder 构建「生成分析节点参数」执行器并注入内置工具体系。
func NewScriptNodeCreator ¶
func NewScriptNodeCreator( workflowSvc interfaces.WorkflowService, analysisRepo interfaces.AnalysisRepository, dataSvc interfaces.DataService, preparer prepare.NodeRuntimePreparer, cfg *config.Config, ) runtimecontext.AnalysisNodeCreator
NewScriptNodeCreator 构建「为已有脚本创建分析节点」执行器并注入内置工具体系。
Types ¶
This section is empty.
Source Files