exec

Sep 28, 2026

Changes in this version

+ var ErrReplayDispatchUnrecorded = errors.New(...)

+ type DispatchResult struct

+ Error string

+ Output any

+ type InvocationReplay struct

+ CreatedAt timex.DateTime

+ ID string

+ Payload string

+ type ReplayPayload struct

+ Dispatches []DispatchResult

+ Input any

+ Request *integration.InboundRequest

+ type ReplayResult struct

+ DefinitionChanged bool

+ DurationMs int64

+ Error string

+ FailureKind integration.FailureKind

+ HTTPTrace []integration.HTTPExchange

+ Input json.RawMessage

+ Output json.RawMessage

+ type Replayer struct

+ func NewReplayer(invoker *Invoker, receiver *Receiver) *Replayer

+ func (rp *Replayer) Replay(ctx context.Context, logID, script string) (*ReplayResult, error)

Jul 21, 2026

Changes in this version

+ var ErrInvalidCodesOption = errors.New("codes: invalid options")

Jul 17, 2026

Changes in this version

+ var ErrAbsoluteURLNotAllowed = errors.New(...)

+ var ErrBlankHandlerContract = errors.New("integration: inbound handler declares no contract code")

+ var ErrDuplicateHandlerContract = errors.New("integration: duplicate inbound handler for contract")

+ var ErrEnvelopeRequestNotObject = errors.New("integration: request envelope script must return the request object")

+ var ErrOutputNotSerializable = errors.New("integration: script output is not JSON-serializable")

+ var ErrRedirectModeUnsupported = errors.New("integration: only the default 'follow' redirect mode is supported")

+ func CallTimeout(system *integration.System) time.Duration

+ func NewTableRouteResolver(db orm.DB) integration.RouteResolver

+ type ConnectionCheck struct

+ Database *DatabaseProbe

+ HTTP *HTTPProbe

+ type DatabaseProbe struct

+ DurationMs int64

+ Error string

+ Reachable bool

+ Version string

+ type DryRunResult struct

+ Error string

+ FailureKind integration.FailureKind

+ Output any

+ Trace []integration.HTTPExchange

+ type HTTPProbe struct

+ DurationMs int64

+ Error string

+ Reachable bool

+ Status int

+ StatusText string

+ type InboundDryRunResult struct

+ DispatchedInput any

+ Error string

+ FailureKind integration.FailureKind

+ Reply any

+ type Invoker struct

+ func NewInvoker(db orm.DB, engine *js.Engine, registry *auth.OutboundRegistry, ...) *Invoker

+ func (inv *Invoker) DryRun(ctx context.Context, contract *integration.Contract, ...) *DryRunResult

+ func (inv *Invoker) Invoke(ctx context.Context, contract string, input any, ...) (*integration.Result, error)

+ func (inv *Invoker) ReleaseSystem(ctx context.Context, systemCode string) error

+ func (inv *Invoker) Stats() []integration.InvocationStats

+ func (inv *Invoker) TestConnection(ctx context.Context, system *integration.System, method, path string) (*ConnectionCheck, error)

+ type Receiver struct

+ func NewReceiver(invoker *Invoker, codec *definition.SecretCodec, schemes *auth.InboundRegistry, ...) (*Receiver, error)

+ func (r *Receiver) DryRun(ctx context.Context, contract *integration.Contract, ...) *InboundDryRunResult

+ func (r *Receiver) Receive(ctx context.Context, req *integration.InboundRequest) (any, error)