probe

Jan 22, 2026

Changes in this version

+ type DagRenderer interface

+ Render func() string

+ type DagRendererBase struct

+ func NewDagRendererBase(w *Workflow) DagRendererBase

+ func (b *DagRendererBase) ExpandPath(path string) string

+ func (b *DagRendererBase) GetEvaluatedVars() map[string]any

+ func (b *DagRendererBase) ResolvePath(path string) string

type Job

+ func LoadEmbeddedJob(path string) (*Job, error)

Jan 18, 2026

Changes in this version

+ type DagAsciiJobNode struct

+ CenterX int

+ HasChildren bool

+ Job *Job

+ JobID string

+ Level int

+ Lines []string

+ Width int

+ type DagAsciiRenderer struct

+ func NewDagAsciiRenderer(w *Workflow) *DagAsciiRenderer

+ func (r *DagAsciiRenderer) Render() string

+ type DagMermaidRenderer struct

+ func NewDagMermaidRenderer(w *Workflow) *DagMermaidRenderer

+ func (r *DagMermaidRenderer) Render() string

type Probe

+ func (p *Probe) DagAscii() (string, error)

+ func (p *Probe) DagMermaid() (string, error)

type Workflow

+ func (w *Workflow) RenderDagAscii() string

+ func (w *Workflow) RenderDagMermaid() string

Jan 10, 2026

Changes in this version

+ const DefaultStepTimeout

type Step

+ Timeout Interval

Oct 17, 2025

Changes in this version

type StepRepeatCounter

+ RepeatTotal int

Oct 7, 2025

Changes in this version

type Repeat

+ Async bool

Oct 6, 2025

Changes in this version

+ const DefaultMaxAttempts

+ const DefaultMaxRepeatCount

+ const EnvMaxAttempts

+ const EnvMaxRepeatCount

type Repeat

+ func (r *Repeat) Validate() error

type StepRetry

+ func (s *StepRetry) Validate() error

Aug 31, 2025

Changes in this version

+ func IsTextualMimeType(contentType string) bool

+ func MapToStruct(m map[string]any) (*structpb.Struct, error)

+ func ProcessHttpBody(data []byte, contentType string) (string, string, error)

+ func SaveBinaryToTempFile(data []byte, contentType string) (string, error)

+ func StructToMap(s *structpb.Struct) map[string]any

+ func TruncateMapStringAny(params map[string]any, maxLen int) map[string]any

type Expr

+ func (e *Expr) EvalTemplateWithTypePreservation(input string, env any) (any, error)

Aug 19, 2025

Changes in this version

+ const IconTriangle

+ func FromAnySlice[T any](s []any) ([]T, error)

+ func ToAnySlice[T any](s []T) []any

type StepContext

+ RepeatIndex int

Aug 15, 2025

Changes in this version

+ type ExitStatus int

+ const ExitStatusFailure

+ const ExitStatusSuccess

+ func (e ExitStatus) Int() int

+ func (e ExitStatus) String() string

type Step

+ Retry *StepRetry

type StepContext

+ Status int

+ type StepRetry struct

+ InitialDelay Interval

+ Interval Interval

+ MaxAttempts int

Aug 14, 2025

Changes in this version

+ type ActionRunner interface

+ RunActions func(name string, args []string, with map[string]any, verbose bool) (map[string]any, error)

type Job

+ func (j *Job) RunIndependently(vars map[string]any, printer *Printer, jobID string) (bool, map[string]any, string, string, time.Duration)

+ type MockActionRunner struct

+ Errors map[string]error

+ Results map[string]map[string]any

+ func NewMockActionRunner() *MockActionRunner

+ func (m *MockActionRunner) RunActions(name string, args []string, with map[string]any, verbose bool) (map[string]any, error)

+ func (m *MockActionRunner) SetError(actionName string, err error)

+ func (m *MockActionRunner) SetResult(actionName string, result map[string]any)

+ type PluginActionRunner struct

+ func (p *PluginActionRunner) RunActions(name string, args []string, with map[string]any, verbose bool) (map[string]any, error)

type Printer

+ func (p *Printer) Fprint(w io.Writer, a ...any)

+ func (p *Printer) Fprintf(w io.Writer, f string, a ...any)

+ func (p *Printer) Fprintln(w io.Writer, a ...any)

+ type ResponseTime struct

+ Duration string

+ Sec float64

type Step

+ Iteration []map[string]any

Aug 8, 2025

Changes in this version

type StepContext

+ RTSec float64

type StepResult

+ RTSec float64

Aug 8, 2025

Changes in this version

type Printer

+ func (p *Printer) GenerateReportOnlySteps(rs *Result) string

Aug 5, 2025

Changes in this version

type Outputs

+ func (o *Outputs) GetAllWithFlat() map[string]any

+ func (o *Outputs) GetConflicts() map[string][]string

+ func (o *Outputs) GetFlat(outputName string) (any, bool)

type Printer

+ func (p *Printer) GenerateReport(rs *Result, isFooter bool) string

type Step

+ Expr *Expr

+ Idx int

type StepContext

+ Report string

type StepResult

+ Report string

Aug 4, 2025

Changes in this version

type Job

+ SkipIf string

Aug 3, 2025

Changes in this version

+ func ConvertBodyToJson(data map[string]string) error

+ func ConvertNumericStrings(data map[string]any) map[string]any

+ func HeaderToStringValue(data map[string]any) map[string]any

Jul 30, 2025

Changes in this version

type Printer

+ func (p *Printer) PrintEchoContent(content string)

+ func (p *Printer) PrintMapData(data map[string]any)

+ func (p *Printer) PrintRequestResponse(stepIdx int, stepName string, req, res map[string]any, rt string)

+ func (p *Printer) PrintTestResult(success bool, testExpr string, context interface{})

Jul 29, 2025

Changes in this version

+ const MaxLogStringLength

+ const MaxStringLength

+ func GetTruncationMessage() string

+ func TruncateMapStringString(params map[string]string, maxLen int) map[string]string

+ func TruncateString(s string, maxLen int) string

Jul 28, 2025

Changes in this version

+ type Executor struct

+ func NewExecutor(w *Workflow, job *Job) *Executor

+ func (e *Executor) Execute(ctx JobContext) bool

type JobContext

+ CurrentJobID string

+ JobScheduler *JobScheduler

+ Result *Result

+ type JobResult struct

+ EndTime time.Time

+ JobID string

+ JobName string

+ StartTime time.Time

+ Status string

+ StepResults []StepResult

+ Success bool

type Printer

+ Buffer map[string]*strings.Builder

+ BufferIDs []string

+ func (p *Printer) AddSpinnerSuffix(txt string)

+ func (p *Printer) PrintHeader(name, description string)

+ func (p *Printer) PrintReport(rs *Result)

+ func (p *Printer) StartSpinner()

+ func (p *Printer) StopSpinner()

+ type Result struct

+ Jobs map[string]*JobResult

+ func NewResult() *Result

+ func (rs *Result) AddStepResult(jobID string, stepResult StepResult)

type StepResult

+ RepeatCounter *StepRepeatCounter

Jul 25, 2025

Changes in this version

+ const IconSkip

+ const IconWait

+ func IsErrorType(err error, errorType ErrorType) bool

type Config

+ Printer PrintWriter

+ type ErrorType string

+ const ErrorTypeAction

+ const ErrorTypeConfiguration

+ const ErrorTypeDependency

+ const ErrorTypeExecution

+ const ErrorTypeFile

+ const ErrorTypeNetwork

+ const ErrorTypeValidation

type JobContext

+ Outputs *Outputs

+ Printer PrintWriter

+ type LogLevel int

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelWarn

+ type Outputs struct

+ func NewOutputs() *Outputs

+ func (o *Outputs) Get(stepID string) (map[string]any, bool)

+ func (o *Outputs) GetAll() map[string]map[string]any

+ func (o *Outputs) Set(stepID string, outputs map[string]any)

+ type PrintWriter interface

+ LogDebug func(format string, args ...interface{})

+ LogError func(format string, args ...interface{})

+ LogInfo func(format string, args ...interface{})

+ LogWarn func(format string, args ...interface{})

+ PrintError func(format string, args ...interface{})

+ PrintJobName func(name string)

+ PrintJobOutput func(output string)

+ PrintJobResult func(jobName string, status StatusType, duration float64)

+ PrintSeparator func()

+ PrintStepRepeatResult func(stepIdx int, counter StepRepeatCounter, hasTest bool)

+ PrintStepRepeatStart func(stepIdx int, stepName string, repeatCount int)

+ PrintStepResult func(step StepResult)

+ PrintVerbose func(format string, args ...interface{})

+ PrintWorkflowHeader func(name, description string)

+ PrintWorkflowSummary func(totalTime float64, successCount, totalJobs int)

+ type Printer struct

+ func NewPrinter(verbose bool) *Printer

+ func (p *Printer) LogDebug(format string, args ...interface{})

+ func (p *Printer) LogError(format string, args ...interface{})

+ func (p *Printer) LogInfo(format string, args ...interface{})

+ func (p *Printer) LogWarn(format string, args ...interface{})

+ func (p *Printer) PrintError(format string, args ...interface{})

+ func (p *Printer) PrintJobName(name string)

+ func (p *Printer) PrintJobOutput(output string)

+ func (p *Printer) PrintJobResult(jobName string, status StatusType, duration float64)

+ func (p *Printer) PrintSeparator()

+ func (p *Printer) PrintStepRepeatResult(stepIdx int, counter StepRepeatCounter, hasTest bool)

+ func (p *Printer) PrintStepRepeatStart(stepIdx int, stepName string, repeatCount int)

+ func (p *Printer) PrintStepResult(step StepResult)

+ func (p *Printer) PrintVerbose(format string, args ...interface{})

+ func (p *Printer) PrintWorkflowHeader(name, description string)

+ func (p *Printer) PrintWorkflowSummary(totalTime float64, successCount, totalJobs int)

type Probe

+ func NewWithPrinter(path string, v bool, printer PrintWriter) *Probe

+ type ProbeError struct

+ Cause error

+ Context map[string]interface{}

+ Message string

+ Operation string

+ Type ErrorType

+ func NewActionError(operation, message string, cause error) *ProbeError

+ func NewConfigurationError(operation, message string, cause error) *ProbeError

+ func NewDependencyError(operation, message string, cause error) *ProbeError

+ func NewExecutionError(operation, message string, cause error) *ProbeError

+ func NewFileError(operation, message string, cause error) *ProbeError

+ func NewNetworkError(operation, message string, cause error) *ProbeError

+ func NewProbeError(errorType ErrorType, operation, message string, cause error) *ProbeError

+ func NewValidationError(operation, message string, cause error) *ProbeError

+ func (e *ProbeError) Error() string

+ func (e *ProbeError) Is(target error) bool

+ func (e *ProbeError) Unwrap() error

+ func (e *ProbeError) WithContext(key string, value interface{}) *ProbeError

+ type SilentPrinter struct

+ func NewSilentPrinter() *SilentPrinter

+ func (s *SilentPrinter) LogDebug(format string, args ...interface{})

+ func (s *SilentPrinter) LogError(format string, args ...interface{})

+ func (s *SilentPrinter) LogInfo(format string, args ...interface{})

+ func (s *SilentPrinter) LogWarn(format string, args ...interface{})

+ func (s *SilentPrinter) PrintError(format string, args ...interface{})

+ func (s *SilentPrinter) PrintJobName(name string)

+ func (s *SilentPrinter) PrintJobOutput(output string)

+ func (s *SilentPrinter) PrintJobResult(jobName string, status StatusType, duration float64)

+ func (s *SilentPrinter) PrintSeparator()

+ func (s *SilentPrinter) PrintStepRepeatResult(stepIdx int, counter StepRepeatCounter, hasTest bool)

+ func (s *SilentPrinter) PrintStepRepeatStart(stepIdx int, stepName string, repeatCount int)

+ func (s *SilentPrinter) PrintStepResult(step StepResult)

+ func (s *SilentPrinter) PrintVerbose(format string, args ...interface{})

+ func (s *SilentPrinter) PrintWorkflowHeader(name, description string)

+ func (s *SilentPrinter) PrintWorkflowSummary(totalTime float64, successCount, totalJobs int)

type StatusType

+ const StatusSkipped

type Step

+ ID string

+ Outputs map[string]string

+ SkipIf string

+ Wait string

type StepContext

+ Outputs map[string]map[string]any

type StepResult

+ WaitTime string

Jul 22, 2025

Changes in this version

+ const IconCircle

+ const IconError

+ const IconSuccess

+ const IconWarning

+ type BufferedJobExecutor struct

+ func NewBufferedJobExecutor(w *Workflow) *BufferedJobExecutor

+ func (e *BufferedJobExecutor) Execute(job *Job, jobID string, ctx JobContext, config ExecutionConfig) ExecutionResult

+ type ExecutionConfig struct

+ HasDependencies bool

+ JobScheduler *JobScheduler

+ UseBuffering bool

+ UseParallel bool

+ WorkflowOutput *WorkflowOutput

+ type ExecutionResult struct

+ Duration time.Duration

+ Error error

+ Output string

+ Success bool

+ type Interval struct

+ func (i *Interval) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (i Interval) MarshalYAML() (interface{}, error)

type JobContext

+ IsRepeating bool

+ Output OutputWriter

+ RepeatCurrent int

+ RepeatTotal int

+ StepCounters map[int]StepRepeatCounter

+ UseBuffering bool

+ type JobExecutor interface

+ Execute func(job *Job, jobID string, ctx JobContext, config ExecutionConfig) ExecutionResult

+ type JobOutput struct

+ Buffer strings.Builder

+ EndTime time.Time

+ JobID string

+ JobName string

+ StartTime time.Time

+ Status string

+ Success bool

type JobScheduler

+ func (js *JobScheduler) MarkJobsWithFailedDependencies() []string

+ type Output struct

+ func NewOutput(verbose bool) *Output

+ func (o *Output) PrintError(format string, args ...interface{})

+ func (o *Output) PrintJobName(name string)

+ func (o *Output) PrintJobOutput(output string)

+ func (o *Output) PrintJobResult(jobName string, status StatusType, duration float64)

+ func (o *Output) PrintSeparator()

+ func (o *Output) PrintStepRepeatResult(stepIdx int, counter StepRepeatCounter, hasTest bool)

+ func (o *Output) PrintStepRepeatStart(stepIdx int, stepName string, repeatCount int)

+ func (o *Output) PrintStepResult(step StepResult)

+ func (o *Output) PrintVerbose(format string, args ...interface{})

+ func (o *Output) PrintWorkflowHeader(name, description string)

+ func (o *Output) PrintWorkflowSummary(totalTime float64, successCount, totalJobs int)

+ type OutputWriter interface

+ PrintError func(format string, args ...interface{})

+ PrintJobName func(name string)

+ PrintJobOutput func(output string)

+ PrintJobResult func(jobName string, status StatusType, duration float64)

+ PrintSeparator func()

+ PrintStepRepeatResult func(stepIdx int, counter StepRepeatCounter, hasTest bool)

+ PrintStepRepeatStart func(stepIdx int, stepName string, repeatCount int)

+ PrintStepResult func(step StepResult)

+ PrintVerbose func(format string, args ...interface{})

+ PrintWorkflowHeader func(name, description string)

+ PrintWorkflowSummary func(totalTime float64, successCount, totalJobs int)

+ type ParallelJobExecutor struct

+ func NewParallelJobExecutor(w *Workflow) *ParallelJobExecutor

+ func (e *ParallelJobExecutor) Execute(job *Job, jobID string, ctx JobContext, config ExecutionConfig) ExecutionResult

+ type SequentialJobExecutor struct

+ func NewSequentialJobExecutor(w *Workflow) *SequentialJobExecutor

+ func (e *SequentialJobExecutor) Execute(job *Job, jobID string, ctx JobContext, config ExecutionConfig) ExecutionResult

+ type StatusType int

+ const StatusError

+ const StatusSuccess

+ const StatusWarning

+ type StepRepeatCounter struct

+ FailureCount int

+ LastResult bool

+ Name string

+ Output strings.Builder

+ SuccessCount int

+ type StepResult struct

+ EchoOutput string

+ HasTest bool

+ Index int

+ Name string

+ RT string

+ Status StatusType

+ TestOutput string

type Workflow

+ Description string

+ type WorkflowOutput struct

+ Jobs map[string]*JobOutput

+ func NewWorkflowOutput() *WorkflowOutput

Jul 14, 2025

Changes in this version

+ func DisableSecurityExit(disabled bool)

type Config

+ RT bool

type Job

+ ID string

+ Needs []string

+ type JobScheduler struct

+ func NewJobScheduler() *JobScheduler

+ func (js *JobScheduler) AddJob(job *Job) error

+ func (js *JobScheduler) AllJobsCompleted() bool

+ func (js *JobScheduler) CanRunJob(jobID string) bool

+ func (js *JobScheduler) GetRepeatInfo(jobID string) (current, target int)

+ func (js *JobScheduler) GetRunnableJobs() []string

+ func (js *JobScheduler) IncrementRepeatCounter(jobID string)

+ func (js *JobScheduler) SetJobStatus(jobID string, status JobStatus, success bool)

+ func (js *JobScheduler) ShouldRepeatJob(jobID string) bool

+ func (js *JobScheduler) ValidateDependencies() error

+ type JobStatus int

+ const JobCompleted

+ const JobFailed

+ const JobPending

+ const JobRunning

type Probe

+ Config Config

type Step

+ Iter []map[string]any

+ func (st *Step) Do(jCtx *JobContext)

+ func (st *Step) DoEcho()

+ func (st *Step) DoEchoWithSequentialPrint()

+ func (st *Step) DoTest() (string, bool)

+ func (st *Step) DoTestWithSequentialPrint() bool

+ func (st *Step) ShowRequestResponse(name string)

+ type StepContext struct

+ Logs []map[string]any

+ RT string

+ Req map[string]any

+ Res map[string]any

+ Vars map[string]any

Jan 28, 2025

Changes in this version

+ func AnyToString(value any) (string, bool)

+ func DiffJSON(src, target map[string]any) string

+ func MatchJSON(src, target map[string]any) bool

+ func MergeMaps(base, over map[string]any) map[string]any

type Expr

+ func (e *Expr) EvalOrEvalTemplate(input string, env any) (string, error)

+ func (e *Expr) EvalTemplateMap(input map[string]any, env any) map[string]any

+ func (e *Expr) Options(env any) []ex.Option

type Step

+ Vars map[string]any

+ func (s Step) SetCtx(j JobContext, req, res map[string]any) TestContext

Jan 22, 2025

Changes in this version

+ func EnvMap() map[string]string

+ func StrmapToAnymap(strmap map[string]string) map[string]any

type Expr

+ func (e *Expr) Eval(s string, env any) (string, error)

type JobContext

+ Vars map[string]string

type TestContext

+ Vars map[string]string

type Workflow

+ Vars map[string]string

+ func (w *Workflow) Env() map[string]string

Jan 14, 2025

Changes in this version

+ type Expr struct

+ func NewExpr() *Expr

+ func (e *Expr) EvalTemplate(exprs map[string]any, env any) map[string]any

+ func (e *Expr) EvalTemplateStr(s string, env any) (string, error)

type JobContext

+ Failed bool

+ func (j *JobContext) SetFailed()

type Probe

+ func (p *Probe) ExitStatus() int

type Step

+ Echo string

type Workflow

+ func (w *Workflow) SetExitStatus(isErr bool)

Jan 8, 2025

Changes in this version

+ var BuiltinCmd = "builtin-actions"

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ func AssignStruct(pa ActionsParams, st any) error

+ func EvalExpr(ex string, env any) (any, error)

+ func EvaluateExprs(exprs map[string]any, env any) map[string]any

+ func FlattenInterface(i any) map[string]string

+ func MapToStructByTags(params map[string]any, dest any) error

+ func MergeStringMaps(base map[string]string, over map[string]any) map[string]string

+ func RunActions(name string, args []string, with map[string]any, verbose bool) (map[string]any, error)

+ func StructToMapByTags(src any) (map[string]any, error)

+ func TitleCase(st string, char string) string

+ func UnflattenInterface(flatMap map[string]string) map[string]any

+ type Actions interface

+ Run func(args []string, with map[string]string) (map[string]string, error)

+ type ActionsArgs []string

+ type ActionsClient struct

+ func (m *ActionsClient) Run(args []string, with map[string]string) (map[string]string, error)

+ type ActionsParams map[string]string

+ type ActionsPlugin struct

+ Impl Actions

+ func (p *ActionsPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (any, error)

+ func (p *ActionsPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type ActionsServer struct

+ Impl Actions

+ func (m *ActionsServer) Run(ctx context.Context, req *pb.RunRequest) (*pb.RunResponse, error)

+ type Config struct

+ Log io.Writer

+ Verbose bool

+ type Job struct

+ Defaults any

+ Name string

+ Repeat *Repeat

+ Steps []Step

+ func (j *Job) Start(ctx JobContext)

+ type JobContext struct

+ Envs map[string]string

+ Logs []map[string]any

+ type Probe struct

+ FilePath string

+ func New(path string, v bool) *Probe

+ func (p *Probe) Do() error

+ func (p *Probe) Load() error

+ type Repeat struct

+ Count int

+ Interval int

+ type Step struct

+ Name string

+ Test string

+ Uses string

+ With map[string]any

+ type TestContext struct

+ Envs map[string]string

+ Logs []map[string]any

+ Req map[string]any

+ Res map[string]any

+ func NewTestContext(j JobContext, req, res map[string]any) TestContext

+ type ValidationError struct

+ func (e *ValidationError) AddMessage(s string)

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) HasError() bool

+ type Workflow struct

+ Jobs []Job

+ Name string

+ func (w *Workflow) Start(c Config)