executor

type AsyncLoadFn func(graphsync.RequestID, ipld.Link) <-chan types.AsyncLoadResult

type ExecutionEnv struct {
	Ctx              context.Context
	SendRequest      func(peer.ID, gsmsg.GraphSyncRequest)
	RunBlockHooks    func(p peer.ID, response graphsync.ResponseData, blk graphsync.BlockData) error
	TerminateRequest func(graphsync.RequestID)
	WaitForMessages  func(ctx context.Context, resumeMessages chan graphsync.ExtensionData) ([]graphsync.ExtensionData, error)
	Loader           AsyncLoadFn
}

type RequestExecution struct {
	Ctx                  context.Context
	P                    peer.ID
	TerminalError        chan error
	Request              gsmsg.GraphSyncRequest
	LastResponse         *atomic.Value
	DoNotSendCids        *cid.Set
	NodePrototypeChooser traversal.LinkTargetNodePrototypeChooser
	ResumeMessages       chan []graphsync.ExtensionData
	PauseMessages        chan struct{}
}