orchestrator

Documentation

Index

• type ParallelProcessor
  • func BuildParallelProcessor(ctx context.Context, reqPlan *plan.RequestPlan, ...) (*ParallelProcessor, error)
  • func (b *ParallelProcessor) Run(ctx context.Context) (storeMap store.Map, err error)
  • func (b *ParallelProcessor) Stages() *stage.Stages

Types

type ParallelProcessor

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

func BuildParallelProcessor

func BuildParallelProcessor(
	ctx context.Context,
	reqPlan *plan.RequestPlan,
	workerFactory work.WorkerFactory,
	maxParallelJobs int,
	execGraph *exec.Graph,
	execoutStorage *execout.Configs,
	respFunc func(resp substreams.ResponseFromAnyTier) error,
	storeConfigs store.ConfigMap,
) (*ParallelProcessor, error)

BuildParallelProcessor is only called on tier1

func (*ParallelProcessor) Run

func (b *ParallelProcessor) Run(ctx context.Context) (storeMap store.Map, err error)

func (*ParallelProcessor) Stages

func (b *ParallelProcessor) Stages() *stage.Stages