Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NamedStage ¶
type NamedStage struct {
// contains filtered or unexported fields
}
type Option ¶
func WithStageLoader ¶
func WithStageLoader(loader StageLoader) Option
type PluginLoader ¶
type PluginLoader interface {
LoadPlugin(name string) graph.IOWorkerVertex[[]byte]
}
type Stage ¶
type Stage struct {
NamedStage
Parents []string `yaml:"parents"`
PluginPath string `yaml:"pluginPath"`
Plugin string `yaml:"plugin"`
Config any `yaml:"config"`
Pipe []map[string]yaml.Node `yaml:"pipe"`
}
func (Stage) LoadPlugin ¶
func (st Stage) LoadPlugin(name string) graph.IOWorkerVertex[[]byte]
type StageLoader ¶
type StageLoader func(name string, yml *yaml.Node) (PluginLoader, error)
func SimpleStageLoader ¶
func SimpleStageLoader(getPluginLoader func() PluginLoader) StageLoader
type Template ¶
type Template struct {
Name string `yaml:"name" json:"name"`
Description string `yaml:"description" json:"description"`
Version string `yaml:"version" json:"version"`
Author string `yaml:"author" json:"author"`
Stages map[string]*yaml.Node `yaml:"stages" json:"stages"`
// contains filtered or unexported fields
}
func (Template) IterPluginLoader ¶
func (t Template) IterPluginLoader() iter.Seq2[string, PluginLoader]
func (Template) WorkerVertexIterator ¶
Click to show internal directories.
Click to hide internal directories.