pipeline

type ClonePolicy int

type Cloner interface {
	Clone() Cloner
}

type ContentData struct {
	Name   string
	Data   string
	Format string
}

type Flusher interface {
	// Flush any data in the node.
	// There's no reason to reallocate or replace the RunOutput.Pins,
	// just append to what's there.
	Flush(*State, *RunOutput) error
}

type NewNodeFunc func() Node

type Node interface {
	Runner
}

type Pin struct {
	Name    string
	Payload Cloner
	Policy  ClonePolicy
}

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

type RunInput struct {
	Pins []Pin
}

type RunOutput struct {
	Pins []Pin
}

type Runner interface {
	// Run the supplied pins, converting the input to output.
	// There's no reason to reallocate or replace the RunOutput.Pins,
	// just append to what's there.
	Run(*State, RunInput, *RunOutput) error
}

type StartInput interface {
	SetNodeData(any)
}

type Starter interface {
	// One-time notification that the node is starting a run.
	// Clients that want to use the NodeData pattern can assign
	// the NodeData field and it will be available during the Run.
	Start(StartInput) error
}

type State struct {
	// The data set in Starter.Start.
	NodeData any
}

type StructData struct {
	// The name of the source struct.
	Name string

	// All exported fields in the struct.
	Fields []StructField

	// All unexported fields in the struct. It should be rare
	// for a client to want access to these fields, so we keep
	// them in a separate slice to avoid polluting the fields list.
	UnexportedFields []StructField
}

type StructField struct {
	// The name of the field in the original source.
	Name string
	// The Go type of the field (string, float64, etc.)
	Type string
	// Tag data for the field.
	Tag string
}