Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + const APP_NAME + const EnableScriptVerificationAtBuild + const PARAM_BUILD_OUTPUT_DIR + const PARAM_DEBUG_SCRIPT + const PARAM_OUTPUT_ENV_FILE + const PARAM_SCRIPT_DIR + const PARAM_SHARED_DATA_DIR + const PARAM_WORKSPACE + func ParseOutputParams(filePath string) (map[string]string, error) + type AssetCopier interface + GetAssets func() []string + GetMetadata func() *CommandMetadata + GetWorkDir func() string + SetEnv func(key, value string) + type CancleRequest struct + WorkDir string + type CommandMetadata struct + CreatedAt time.Time + CreatedBy string + Description string + EnvVars map[string]string + ID string + Name string + RefTask string + Tags []string + Timeout time.Duration + WorkDir string + func (m *CommandMetadata) GetEnvVar(key string) string + type DeleteWorkDirRequest struct + WorkDir string + func NewDeleteWorkDirRequest(workDir string) *DeleteWorkDirRequest + type ExecuteCommandRequest struct + Assets []string + Command string + func NewExecuteCommandRequest(command string, workDir string) *ExecuteCommandRequest + func (r *ExecuteCommandRequest) GetAssets() []string + func (r *ExecuteCommandRequest) GetMetadata() *CommandMetadata + func (r *ExecuteCommandRequest) GetWorkDir() string + func (r *ExecuteCommandRequest) SetAssets(assetdir ...string) + func (s ExecuteCommandRequest) EnableCollectUploadFiles() + func (s ExecuteCommandRequest) GetResultFilePath() string + func (s ExecuteCommandRequest) SetCollectFiles(filenames ...string) + func (s ExecuteCommandRequest) SetCreateProcessGroup(enable bool) + func (s ExecuteCommandRequest) SetEnv(key, value string) + func (s ExecuteCommandRequest) SetEnvAll(params map[string]string) + func (s ExecuteCommandRequest) SetEnvFromParams(getParam func(string) string, paramKeys ...string) + func (s ExecuteCommandRequest) SetEnvMultiple(envVars map[string]string) + func (s ExecuteCommandRequest) SetLogCallback(callback func(string)) + func (s ExecuteCommandRequest) SetLogFile(logFile string) + func (s ExecuteCommandRequest) SetMetadata(metadata *CommandMetadata) + func (s ExecuteCommandRequest) SetResultFile(resultFile string) + func (s ExecuteCommandRequest) SetTimeout(timeout time.Duration) + func (s ExecuteCommandRequest) SetUseProcessGroupKill(enable bool) + func (s ExecuteCommandRequest) UpdateMetadata(updates map[string]any) + func (s ExecuteCommandRequest) WriteDebugScript(scriptPath string, args []string) (string, error) + type ExecuteScriptRequest struct + Args []string + Assets []string + ScriptPath string + func NewExecuteScriptRequest(scriptPath string, workDir string, args ...string) *ExecuteScriptRequest + func (r *ExecuteScriptRequest) GetAssets() []string + func (r *ExecuteScriptRequest) GetMetadata() *CommandMetadata + func (r *ExecuteScriptRequest) GetWorkDir() string + func (r *ExecuteScriptRequest) SetAssets(assetdir ...string) + func (s ExecuteScriptRequest) EnableCollectUploadFiles() + func (s ExecuteScriptRequest) GetResultFilePath() string + func (s ExecuteScriptRequest) SetCollectFiles(filenames ...string) + func (s ExecuteScriptRequest) SetCreateProcessGroup(enable bool) + func (s ExecuteScriptRequest) SetEnv(key, value string) + func (s ExecuteScriptRequest) SetEnvAll(params map[string]string) + func (s ExecuteScriptRequest) SetEnvFromParams(getParam func(string) string, paramKeys ...string) + func (s ExecuteScriptRequest) SetEnvMultiple(envVars map[string]string) + func (s ExecuteScriptRequest) SetLogCallback(callback func(string)) + func (s ExecuteScriptRequest) SetLogFile(logFile string) + func (s ExecuteScriptRequest) SetMetadata(metadata *CommandMetadata) + func (s ExecuteScriptRequest) SetResultFile(resultFile string) + func (s ExecuteScriptRequest) SetTimeout(timeout time.Duration) + func (s ExecuteScriptRequest) SetUseProcessGroupKill(enable bool) + func (s ExecuteScriptRequest) UpdateMetadata(updates map[string]any) + func (s ExecuteScriptRequest) WriteDebugScript(scriptPath string, args []string) (string, error) + type ExecutionResult struct + Command string + Duration time.Duration + EndTime *time.Time + Error string + ExitCode int + FileContents map[string]string + Message string + Metadata *CommandMetadata + OutputParams map[string]string + Skipped bool + StartTime time.Time + Success bool + UploadFiles []*UploadFileInfo + func ExecutionSkipped(start time.Time, command string, message string) *ExecutionResult + func ExecutionSuccess(start time.Time, command string) *ExecutionResult + func NewExecutionFailed(start time.Time, command string, err error, exitCode int) *ExecutionResult + func (r *ExecutionResult) CleanRef() *ExecutionResult + func (r *ExecutionResult) SensitiveParams(params ...string) *ExecutionResult + func (r *ExecutionResult) String() string + func (r *ExecutionResult) ToJSON() string + type GetExecutionResultRequest struct + WorkDir string + func NewGetExecutionResultRequest(workDir string) *GetExecutionResultRequest + type ScriptExcutor struct + AssetsDirPrefix string + ScriptDirPrefix string + WorkDirPrefix string + WorkspaceCleanCron string + WorkspaceTTL string + func (r *ScriptExcutor) CleanWorkspace(duration time.Duration) error + func (r *ScriptExcutor) ExecuteCommand(ctx context.Context, in *ExecuteCommandRequest) (*ExecutionResult, error) + func (r *ScriptExcutor) ExecuteScript(ctx context.Context, in *ExecuteScriptRequest) (*ExecutionResult, error) + func (r *ScriptExcutor) Init() error + func (r *ScriptExcutor) InjectEnv(in *shellExecutor) + func (r *ScriptExcutor) Name() string + func (r *ScriptExcutor) ResolveAbsolutePath(path string) (string, error) + func (r *ScriptExcutor) WithPrefixScripPath(scriptName string) string + func (r *ScriptExcutor) WithPrefixWorkSpace(workspace string) string + func (s *ScriptExcutor) Cancle(ctx context.Context, in *CancleRequest) error + func (s *ScriptExcutor) DeleteWorkDir(ctx context.Context, in *DeleteWorkDirRequest) error + func (s *ScriptExcutor) GetExecutionResult(ctx context.Context, in *GetExecutionResultRequest) (*ExecutionResult, error) + type ScriptIntegrityManager struct + func NewScriptIntegrityManager(scriptDir string, enabled bool) *ScriptIntegrityManager + func (m *ScriptIntegrityManager) Disable() + func (m *ScriptIntegrityManager) Enable() + func (m *ScriptIntegrityManager) GetRegisteredScripts() map[string]string + func (m *ScriptIntegrityManager) IsEnabled() bool + func (m *ScriptIntegrityManager) RegisterScripts() error + func (m *ScriptIntegrityManager) VerifyScript(scriptPath string) error + type Service interface + Cancle func(ctx context.Context, in *CancleRequest) error + CleanWorkspace func(duration time.Duration) error + DeleteWorkDir func(ctx context.Context, in *DeleteWorkDirRequest) error + ExecuteCommand func(ctx context.Context, in *ExecuteCommandRequest) (*ExecutionResult, error) + ExecuteScript func(ctx context.Context, in *ExecuteScriptRequest) (*ExecutionResult, error) + GetExecutionResult func(ctx context.Context, in *GetExecutionResultRequest) (*ExecutionResult, error) + func GetService() Service + type UploadFileInfo struct + MD5 string + ModTime string + Name string + Path string + Size int64