unit

type ContextMap map[string]*ExecutionResult

type ControlSignal string

type ControlSignalError struct {
	Signal ControlSignal
	Target string
}

type Executable interface {
	GetUnitMeta() *Unit
	Execute(ctx context.Context, state ContextMap, self *Node) (*ExecutionResult, error)
}

type ExecutableUnit = Executable

type ExecutionResult struct {
	NodeName        string         `json:"node_name,omitempty"`
	Data            any            `json:"data,omitempty"`
	Variables       map[string]any `json:"variables,omitempty"`
	DeleteVariables []string       `json:"delete_variables,omitempty"`
	Stream          bool           `json:"stream,omitempty"`
	Raw             any            `json:"raw,omitempty"`
	Error           string         `json:"error,omitempty"`
	Control         ControlSignal  `json:"control,omitempty"`
	ControlTarget   string         `json:"control_target,omitempty"`
}

type Executor struct {
	Registry    *Registry
	Credentials credential.Resolver
}

type Factory func() Executable

type Input struct {
	Data      any    `json:"data,omitempty"`
	DataType  string `json:"data_type,omitempty"`
	Slottable bool   `json:"slottable,omitempty"`
}

type Node struct {
	ID           string         `json:"id,omitempty"`
	Name         string         `json:"name,omitempty"`
	Input        *Input         `json:"input,omitempty"`
	Params       map[string]any `json:"params,omitempty"`
	ExportFields []string       `json:"export_fields,omitempty"`
}

type Registration struct {
	Name    string
	Factory Factory
}

type Registry struct {
	// contains filtered or unexported fields
}

type Unit struct {
	ID          string `json:"id"`
	UnitName    string `json:"unit_name,omitempty"`
	DisplayName string `json:"display_name,omitempty"`
	Status      string `json:"status,omitempty"`
	ErrMsg      string `json:"err_msg,omitempty"`
	OutputRef   string `json:"output_ref,omitempty"`
}