graph

type Consumer[K any] interface {
	Consume(ctx context.Context, input <-chan K) error
}

type Context interface {
	context.Context
	Initialized()
}

type DefaultIOWorkerVertex[K any] struct {
	IOWorker[K]
	// contains filtered or unexported fields
}

type IOGraph[K any] struct {
	graph.Graph[string, IOWorkerVertex[K]]
}

type IOGraphOption[K any] func(*IOGraph[K])

type IOWorker[K any] interface {
	Run(ctx SyncContext) <-chan error
	SetInput(input <-chan K)
	Output() <-chan K
}

type IOWorkerVertex[K any] interface {
	IOWorker[K]
	GetName() string
	GetParents() []string
}

type Producer[K any] interface {
	Produce(ctx context.Context, yield func(elem K) error) error
}

type Runner[K any] interface {
	Run(ctx context.Context, input <-chan K, yield func(elem K) error) error
}

type SyncContext interface {
	Context
	Initializing()
	Synchronize()
}

type WaitGroupContext struct {
	context.Context
	// contains filtered or unexported fields
}

type Worker[K any] interface {
	Work(ctx context.Context, input K, yield func(elem K) error) error
}