node

Oct 14, 2026

Changes in this version

+ func WithResponseBudget(ctx context.Context, budget *ResponseBudget) context.Context

type RequestExecutionResult

+ func (r *RequestExecutionResult) ReleaseResponse()

+ type ResponseBudget struct

+ func NewResponseBudget(size int64) *ResponseBudget

+ func (b *ResponseBudget) InUse() int64

+ type ResponseReleaser interface

+ ReleaseResponse func()

Oct 14, 2026

Changes in this version

+ const DefaultMaxResponseBytes

+ const ReportedResponseBodyBytes

+ const ResponseTooLargeCode

+ func WithMaxResponseBytes(ctx context.Context, limit int64) context.Context

type RequestExecutionResult

+ ResponseBodyTruncated bool

Oct 14, 2026

Changes in this version

+ func FormatTemplateValue(val any) string

Oct 12, 2026

Changes in this version

type Output

+ Secret bool

Oct 11, 2026

Changes in this version

+ func LookupPath(ref string, get func(key string) (any, bool)) (any, bool)

Oct 1, 2026

Changes in this version

+ func AssertionReferences(n AnyNode) []string

type CompositeAssertion

+ func ResolveAssertions(ctx spi.ExecutionContext, assertions []CompositeAssertion) ([]CompositeAssertion, error)

Sep 30, 2026

Changes in this version

+ type ClosestEvent struct

+ Checks []ExpectationCheck

+ ClaimedBy string

+ RequestID string

+ type ExpectationCheck struct

+ Actual any

+ Expected any

+ Label string

+ Passed bool

+ type ExpectationOutcome struct

+ ArrivedAfterMs *int64

+ Closest *ClosestEvent

+ Name string

+ Passed bool

+ Problem string

+ Received int

+ RequestIDs []string

+ type SelfResolvingNode interface

+ ResolvedReferences func() []string

+ type WebhookExpectation struct

+ Assertions []CompositeAssertion

+ Max *int

+ Min *int

+ Name string

type WebhookWaitData

+ Expect []WebhookExpectation

+ SettleMs int

type WebhookWaitExecutionResult

+ Expectations []ExpectationOutcome

type WebhookWaitNode

+ func (n *WebhookWaitNode) ResolvedReferences() []string

Sep 24, 2026

Changes in this version

type WebhookWaitExecutionResult

+ RecentRequests []map[string]any

Sep 4, 2026

Changes in this version

+ type WebhookWaitData struct

+ TimeoutMs int

+ type WebhookWaitExecutionResult struct

+ DurationMs int64

+ type WebhookWaitNode struct

+ Data WebhookWaitData

+ func AsWebhookWaitNode(n AnyNode) (*WebhookWaitNode, bool)

+ func (n *WebhookWaitNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *WebhookWaitNode) GetData() WebhookWaitData

+ func (n *WebhookWaitNode) InputSchema() []string

+ func (n *WebhookWaitNode) OutputSchema() []string

Aug 23, 2026

Changes in this version

+ func EvaluateAssertions(assertions []CompositeAssertion, rc extractors.ResponseContext) ([]spi.AssertionResult, error)

+ func ExtractOutputs(outputs []Output, rc extractors.ResponseContext) (map[string]any, error)

+ func NewOutputView(outputs map[string]map[string]any) spi.OutputView

+ func NewSkippedResult(nodeType spi.Kind, base spi.BaseExecutionResult) (spi.AnyResult, bool)

+ func RegisterNodeKind(nodeType spi.Kind, decode Decoder, newSkipped SkippedResultFactory)

+ func ValidateOutputs(outputSchema []string, produced map[string]any) error

+ type AnyNode interface

+ GetAssertions func() []CompositeAssertion

+ GetOutputs func() []Output

+ func UnmarshalNode(data []byte) (AnyNode, error)

+ type AssertData struct

+ Target any

+ type AssertExecutionResult struct

+ DurationMs int64

+ func (r *AssertExecutionResult) AssertionContext() extractors.ResponseContext

+ type AssertNode struct

+ Data AssertData

+ func AsAssertNode(node AnyNode) (*AssertNode, bool)

+ func (n *AssertNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *AssertNode) GetData() AssertData

+ func (n *AssertNode) InputSchema() []string

+ func (n *AssertNode) OutputSchema() []string

+ type AssertionContextProvider interface

+ AssertionContext func() extractors.ResponseContext

+ type BaseNode struct

+ Assertions []CompositeAssertion

+ DisplayName string

+ ID string

+ NodeType spi.Kind

+ Outputs []Output

+ RunWhen spi.RunWhen

+ func (bn *BaseNode) GetAssertions() []CompositeAssertion

+ func (bn *BaseNode) GetDisplayName() string

+ func (bn *BaseNode) GetID() string

+ func (bn *BaseNode) GetOutputs() []Output

+ func (bn *BaseNode) GetRunWhen() spi.RunWhen

+ func (bn *BaseNode) GetType() spi.Kind

+ func (bn *BaseNode) InputSchema() []string

+ func (bn *BaseNode) OutputSchema() []string

+ type BranchCase struct

+ Target string

+ When CompositeAssertion

+ type BranchData struct

+ Cases []BranchCase

+ Default string

+ Target any

+ type BranchExecutionResult struct

+ DurationMs int64

+ MatchedTarget string

+ RoutedTargetIDs []string

+ func (r *BranchExecutionResult) RoutedTargets() []string

+ type BranchNode struct

+ Data BranchData

+ func AsBranchNode(candidate AnyNode) (*BranchNode, bool)

+ func (n *BranchNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *BranchNode) GetData() BranchData

+ func (n *BranchNode) InputSchema() []string

+ func (n *BranchNode) OutputSchema() []string

+ type CompositeAssertion struct

+ ExpectedValue any

+ Extractor extractors.AnyExtractor

+ ExtractorType string

+ OperatorType operators.OperatorType

+ func (ca *CompositeAssertion) Evaluate(ctx extractors.ResponseContext) spi.AssertionResult

+ func (ca *CompositeAssertion) UnmarshalJSON(data []byte) error

+ type Decoder func([]byte) (AnyNode, error)

+ type DelayData struct

+ Duration int

+ type DelayExecutionResult struct

+ DelayMs int64

+ DelayUntil time.Time

+ type DelayNode struct

+ Data DelayData

+ func NewDelay(id string, durationMs int) *DelayNode

+ func (n *DelayNode) Always() *DelayNode

+ func (n *DelayNode) DisplayName(name string) *DelayNode

+ func (n *DelayNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *DelayNode) GetData() DelayData

+ func (n *DelayNode) InputSchema() []string

+ func (n *DelayNode) OutputSchema() []string

+ type LoopData struct

+ Body json.RawMessage

+ ContinueOnError bool

+ IndexVar string

+ ItemVar string

+ Items any

+ MaxIterations int

+ type LoopExecutionResult struct

+ DurationMs int64

+ Iterations int

+ func (r *LoopExecutionResult) AssertionContext() extractors.ResponseContext

+ type LoopNode struct

+ Data LoopData

+ func AsLoopNode(candidate AnyNode) (*LoopNode, bool)

+ func (n *LoopNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *LoopNode) GetData() LoopData

+ func (n *LoopNode) GetOutputs() []Output

+ func (n *LoopNode) InputSchema() []string

+ func (n *LoopNode) OutputSchema() []string

+ type ModuleData struct

+ FlowID string

+ InputBindings map[string]any

+ OutputBindings map[string]string

+ type ModuleExecutionResult struct

+ ChildFinalOutputs map[string]any

+ DurationMs int64

+ FlowID string

+ type ModuleNode struct

+ Data ModuleData

+ func AsModuleNode(candidate AnyNode) (*ModuleNode, bool)

+ func (n *ModuleNode) DisplayName(name string) *ModuleNode

+ func (n *ModuleNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *ModuleNode) GetData() ModuleData

+ func (n *ModuleNode) InputBinding(key string, value any) *ModuleNode

+ func (n *ModuleNode) InputSchema() []string

+ func (n *ModuleNode) OutputBinding(parentName, childKey string) *ModuleNode

+ func (n *ModuleNode) OutputSchema() []string

+ type Output struct

+ Extractor extractors.AnyExtractor

+ Name string

+ func (o *Output) UnmarshalJSON(data []byte) error

+ type PollData struct

+ Body json.RawMessage

+ IntervalMs int

+ MaxAttempts int

+ TimeoutMs int

+ type PollExecutionResult struct

+ Attempts int

+ DurationMs int64

+ type PollNode struct

+ Data PollData

+ func AsPollNode(node AnyNode) (*PollNode, bool)

+ func MustAsPollNode(node AnyNode) *PollNode

+ func (n *PollNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *PollNode) GetData() PollData

+ func (n *PollNode) InputSchema() []string

+ func (n *PollNode) OutputSchema() []string

+ type RequestData struct

+ Body any

+ Headers map[string]string

+ Method string

+ QueryParams map[string]any

+ Timeout int

+ URL string

+ type RequestExecutionResult struct

+ DurationMs int64

+ RequestBody any

+ RequestHeaders map[string]string

+ RequestMethod string

+ RequestURL string

+ ResponseBody []byte

+ ResponseBodyParsed any

+ ResponseHeaders map[string][]string

+ ResponseStatusCode int

+ func (r *RequestExecutionResult) AssertionContext() extractors.ResponseContext

+ type RequestNode struct

+ Data RequestData

+ func AsRequestNode(node AnyNode) (*RequestNode, bool)

+ func NewRequest(id string) *RequestNode

+ func (n *RequestNode) Always() *RequestNode

+ func (n *RequestNode) Assert(assertion CompositeAssertion) *RequestNode

+ func (n *RequestNode) Body(body any) *RequestNode

+ func (n *RequestNode) DELETE(url string) *RequestNode

+ func (n *RequestNode) DisplayName(name string) *RequestNode

+ func (n *RequestNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *RequestNode) GET(url string) *RequestNode

+ func (n *RequestNode) GetAssertions() []CompositeAssertion

+ func (n *RequestNode) GetData() RequestData

+ func (n *RequestNode) GetOutputs() []Output

+ func (n *RequestNode) Header(key, value string) *RequestNode

+ func (n *RequestNode) InputSchema() []string

+ func (n *RequestNode) Method(method, url string) *RequestNode

+ func (n *RequestNode) Output(output Output) *RequestNode

+ func (n *RequestNode) OutputSchema() []string

+ func (n *RequestNode) PATCH(url string) *RequestNode

+ func (n *RequestNode) POST(url string) *RequestNode

+ func (n *RequestNode) PUT(url string) *RequestNode

+ func (n *RequestNode) TimeoutMs(ms int) *RequestNode

+ type SchemaInference struct

+ func (si *SchemaInference) ExtractTemplateVariables(data any) []string

+ func (si *SchemaInference) InferRequestNodeInputSchema(data RequestData) []string

+ func (si *SchemaInference) InferRequestNodeOutputSchema(outputs []Output) []string

+ type SetVariableData struct

+ Variables map[string]any

+ type SetVariableExecutionResult struct

+ DurationMs int64

+ func (r *SetVariableExecutionResult) AssertionContext() extractors.ResponseContext

+ type SetVariableNode struct

+ Data SetVariableData

+ func AsSetVariableNode(candidate AnyNode) (*SetVariableNode, bool)

+ func (n *SetVariableNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *SetVariableNode) GetData() SetVariableData

+ func (n *SetVariableNode) InputSchema() []string

+ func (n *SetVariableNode) OutputSchema() []string

+ type SkippedResultFactory func(base spi.BaseExecutionResult) spi.AnyResult

+ type SseData struct

+ CompletionEvent string

+ Headers map[string]string

+ MaxEvents int

+ Method string

+ StopOnAssertionFailure *bool

+ TimeoutMs int

+ URL string

+ type SseExecutionResult struct

+ DurationMs int64

+ EventCount int

+ Events []any

+ RequestMethod string

+ RequestURL string

+ StopReason string

+ type SseNode struct

+ Data SseData

+ func AsSseNode(node AnyNode) (*SseNode, bool)

+ func (n *SseNode) Execute(ctx spi.ExecutionContext) (spi.AnyResult, error)

+ func (n *SseNode) GetData() SseData

+ func (n *SseNode) InputSchema() []string

+ func (n *SseNode) OutputSchema() []string

+ type TemplateResolver struct

+ func NewTemplateResolver(variables map[string]any) *TemplateResolver

+ func NewTemplateResolverWithDynamics(variables map[string]any, dynamic spi.DynamicResolver) *TemplateResolver

+ func (tr *TemplateResolver) Resolve(value any) (any, error)