core

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

type Config struct{}

type EmptySecPlugin struct {
}

type GoTemplateConfig struct {
	Format  string `yaml:"format"`
	Pattern string `yaml:"pattern"`
}

type GoTemplateOption = helper.OptionError[goTemplatePipe]

type IndexableNode[T any] interface {
	BuildIndex()
	Query(query T)
}

type MutableNode[T any] interface {
	Nodable[T]
	AddNode(node ...Nodable[T])
	DeleteNode(node ...string)
}

type Nodable[T any] interface {
	GetName() string
	GetChilds() Nodes[T]
	GetValue() T
}

type Node[T any] struct {
	Name  string                `yaml:"name" json:"name"`
	Nodes map[string]Nodable[T] `yaml:"nodes" json:"nodes"`
	Index NodeIndex
}

type NodeIndex map[string]string

type Nodes[T any] map[string]Nodable[T]

type PipeFunc func(ctx context.Context, input <-chan *pluginctl.DataStream) (<-chan *pluginctl.DataStream, <-chan error)

type Pipeable interface {
	Pipe(ctx context.Context, input <-chan *pluginctl.DataStream) (<-chan *pluginctl.DataStream, <-chan error)
}

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

type SecGraph = graph.Graph[string, SecVertex]

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

type SecVertex struct {
	Name string
	// contains filtered or unexported fields
}

type Stage struct {
	Parents    []string               `yaml:"parents"`
	PluginPath string                 `yaml:"pluginPath"`
	Plugin     string                 `yaml:"plugin"`
	Config     map[string]any         `yaml:"config"`
	Pipe       []map[string]yaml.Node `yaml:"pipe"`
}

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]Stage `yaml:"stages" json:"stages"`
}