processing

type Channel interface {
	Send(ctx context.Context, v *elem.Element)
	Receive(ctx context.Context) (*elem.Element, bool, error)
	Close() error
}

type Processing interface {
	Provider
	Size() int
	Execute(req Request, name ...string)
	Close() error

	CreateChannel() Channel
}

type Provider interface {
	GetPool() Processing
}

type Request interface {
	Execute(ctx context.Context)
}