nodes

type ArrayValueInputPort interface {
	InputPort
	Value() []OutputPort
	Add(port OutputPort) error
	Remove(port OutputPort) error
}

type ConstOutput[T any] struct {
	Ref             Node
	Val             T
	PortName        string
	PortDescription string
}

type Describable interface {
	Description() string
}

type ExecutionRecorder interface {
	CaptureTiming(title string, timing time.Duration)
	CaptureError(err error)
}

type ExecutionReport struct {
	Errors    []string       `json:"errors,omitempty"`   // Any errors that occurred during execution
	Logs      []string       `json:"logs,omitempty"`     // Log messages produced
	TotalTime time.Duration  `json:"totalTime"`          // Total time taken to compute the output
	SelfTime  *time.Duration `json:"selfTime,omitempty"` // Time spent within the node itself, not counting waiting on other outputs
	Steps     []StepTiming   `json:"steps,omitempty"`    // Detailed timing of sub-operations, all sub operation times should result in TotalTime - SelfTime
}

type InputPort interface {
	Port

	// Remove any connections to this port
	Clear()
}

type Named interface {
	Name() string
}

type Node interface {
	Outputs() map[string]OutputPort
	Inputs() map[string]InputPort
}

type NodeState int

type ObservableExecution interface {
	ExecutionReport() ExecutionReport
}

type Output[T any] interface {
	OutputPort
	Value() T
}

type OutputPort interface {
	Port
	Version() int
}

type Pathed interface {
	Path() string
}

type Port interface {

	// Node the port belongs to
	Node() Node

	// Name of the port
	Name() string
}

type SingleValueInputPort interface {
	InputPort
	Value() OutputPort
	Set(port OutputPort) error
}

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

type Stateful interface {
	State() NodeState
}

type StepTiming struct {
	Label    string        `json:"label,omitempty"` // Descriptive name for this step
	Duration time.Duration `json:"duration"`        // Time taken by this step
	Steps    []StepTiming  `json:"steps,omitempty"` // Detailed timing of sub-operations
}

type Struct[T any] struct {
	Data T
	// contains filtered or unexported fields
}

type StructOutput[T any] struct {
	// contains filtered or unexported fields
}

type Typed interface {
	Type() string
}

type Value[T any] struct {
	VersionData
	// contains filtered or unexported fields
}

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

type Versioned interface {
	Version() int
}