process

package

v0.3.1 Latest Latest Go to latest Published: Jul 23, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func BuildBaseEnv(extraEnv map[string]string) []string

BuildBaseEnv 返回当前环境并附加额外的环境变量。

func BuildRunEnv(baseEnv []string, extraEnv []string, modelEnv map[string]string) []string

BuildRunEnv 为 CLI 进程组装环境变量条目。

func LerosMCPTokenEnvVar() string

LerosMCPTokenEnvVar returns the env var name used for CLI MCP bearer token registration.

func NormalizeMCPServerConfig(cfg agent.MCPServerConfig) agent.MCPServerConfig

NormalizeMCPServerConfig fills defaults for an MCP server registration.

func ResolveRunWorkDir(workDir string) (string, error)

ResolveRunWorkDir returns the configured run workdir.

func RunCLICommand(ctx context.Context, cliPath string, args []string, extraEnv []string) error

RunCLICommand runs a CLI command with a bounded timeout.

func ScanJSONLines(r io.Reader, visit func(line string) bool)

ScanJSONLines 扫描换行符分隔的 JSON 日志，支持更大的 token 缓冲区。

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

CmdProcess 实现 os/exec.Cmd 的 Process 接口。

func NewCmdProcess(cmd *exec.Cmd, done <-chan struct{}) *CmdProcess

NewCmdProcess 将 cmd 和调用方拥有的 Wait 完成信号包装为 Process。调用方必须保持 cmd.Wait() 的唯一所有权，并在 Wait 返回后关闭 done。

func (p *CmdProcess) PID() int

PID 返回命令启动后的进程 ID。

func (p *CmdProcess) Stop() error

Stop 优雅地终止子进程，不调用 cmd.Wait 或 cmd.Process.Wait。

关闭流程：

Stop 是幂等的，多次调用安全。

type Process interface {
	PID() int
	Stop() error
}

Process is the minimal lifecycle handle exposed by a provider invocation.