Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunFlow ¶
func RunFlow(ctx context.Context, flowPtr *mflow.Flow, services RunnerServices, reporters *reporter.ReporterGroup) (model.FlowRunResult, error)
func RunMultipleFlows ¶
func RunMultipleFlows(ctx context.Context, fileData []byte, allFlows []mflow.Flow, services RunnerServices, logger *slog.Logger, reporters *reporter.ReporterGroup) error
RunMultipleFlows executes multiple flows based on the run field configuration
Types ¶
type JSRunner ¶
type JSRunner struct {
// contains filtered or unexported fields
}
JSRunner manages the lifecycle of the Node.js worker process
func NewJSRunner ¶
NewJSRunner checks if Node.js is available and returns a runner instance
func (*JSRunner) Client ¶
func (r *JSRunner) Client() node_js_executorv1connect.NodeJsExecutorServiceClient
Client returns the RPC client for the JS executor
type RunnerServices ¶
type RunnerServices struct {
NodeService sflow.NodeService
EdgeService sflow.EdgeService
FlowVariableService sflow.FlowVariableService
Builder *flowbuilder.Builder
JSClient node_js_executorv1connect.NodeJsExecutorServiceClient
}
Source Files
Click to show internal directories.
Click to hide internal directories.