converter

type Converter[T any] struct {
	// Description of the processor.
	Description string `json:"description"`

	// Logger is the pipeline logger.
	Logger sypl.ISypl `json:"-" validate:"required"`

	// Name of the stage.
	Name string `json:"name" validate:"required"`

	// OnFinished is the function that is called when a processor finishes its
	// execution.
	OnFinished OnFinished[T] `json:"-"`

	// Metrics.
	CounterCreated *expvar.Int    `json:"counterCreated" validate:"required,gte=0"`
	CounterRunning *expvar.Int    `json:"counterRunning" validate:"required,gte=0"`
	CounterFailed  *expvar.Int    `json:"counterFailed" validate:"required,gte=0"`
	CounterDone    *expvar.Int    `json:"counterDone" validate:"required,gte=0"`
	Status         *expvar.String `json:"status" validate:"required,gte=0"`
}

type Func[T any] func(p IConverter[T]) IConverter[T]

type IConverter[T any] interface {
	shared.IMeta

	shared.IMetrics

	// GetOnFinished returns the `OnFinished` function.
	GetOnFinished() OnFinished[T]

	// SetOnFinished sets the `OnFinished` function.
	SetOnFinished(onFinished OnFinished[T])

	// Run the converter function.
	Run(ctx context.Context, r io.Reader) (T, error)
}

type OnFinished[T any] func(ctx context.Context, c IConverter[T], r io.Reader, processed []T)