generator

type ContainerProcessor struct {
	Processor[common.TestResultContainer]
}

type IPlugin[T any] interface {
	ReadState(context.Context) error
	Process(context.Context, *T)
	SendState() any
	Merge(context.Context, int, []*common.PluginResult, *common.PluginResult) error
}

type IProcessor[T any] interface {
	SetSources(...string) *Processor[T]
	Process(context.Context, *sync.WaitGroup, *mpb.Bar, *common.PluginResult, func(context.Context, string) *T, func(context.Context, *T))
	Read(context.Context, string) *T
	Write(context.Context, *T)
	GetPlugins() []IPlugin[T]
}

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

type ResultsProcessor struct {
	Processor[common.Test]
}