pkgio

type Pipeline[T1 any] struct {
	Inputs     []Reader[T1]  `json:"inputs,omitempty" yaml:"inputs,omitempty"`
	Processors []Process[T1] `json:"processors,omitempty" yaml:"processors,omitempty"`
	Outputs    []Writer[T1]  `json:"outputs,omitempty" yaml:"outputs,omitempty"`
}

type PkgReader struct {
	PathExists     bool
	Fsys           fsys.FS
	MatchFilesGlob []string
	IgnoreRules    *ignore.Rules
	SkipDir        bool
	Checksum       bool
}

type Process[T1 any] interface {
	Process(context.Context, store.Storer[T1]) (store.Storer[T1], error)
}

type Reader[T1 any] interface {
	Read(context.Context, store.Storer[T1]) (store.Storer[T1], error)
}

type Writer[T1 any] interface {
	Write(context.Context, store.Storer[T1]) error
}