pipeline

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

Manager coordinates splitting, caching, provider calls and aggregation for a specific pipeline kind.

func NewManager(
	kind model.OperationKind,
	cfg config.PipelineConfig,
	p provider.Provider,
	s splitter.Splitter,
	c cache.Store,
	pool *worker.Pool,
	proc processor.OperationProcessor,
) (*Manager, error)

func (m *Manager) Run(ctx context.Context, req model.Request) (model.Response, error)