processor

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

type IProcessor[In any] interface {
	shared.IMeta

	shared.IMetrics

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

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

	// Run the transform function.
	Run(ctx context.Context, in []In) (out []In, err error)
}

type OnFinished[T any] func(ctx context.Context, p IProcessor[T], originalIn []T, processedIn []T)

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

	// Transform function.
	Func shared.Run[T] `json:"-"`

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

	// Name of the processor.
	Name string `json:"name"`

	// 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"`
}