pipeline

type ConcurrentCall func(context.Context) (any, error)

type ConcurrentTask struct {
	Name string
	Call ConcurrentCall
}

type Pipeline[T any] struct {
	StartCall       StartCall[T]
	SequenceTasks   []SequenceTask[T]
	ConcurrentTasks []ConcurrentTask
}

type Result struct {
	Name  string
	Error error
	Value any
}

type SequenceHandler[T any] interface {
	Start(context.Context) error
	Handle(context.Context, T) (T, error)
	Finish(context.Context) error
}

type SequenceTask[T any] struct {
	Name     string
	Capacity uint32
	Call     SequenceHandler[T]
}

type StartCall[T any] func(context.Context, chan<- T) error