Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + type AsyncLoadFn func(graphsync.RequestID, ld.Link) <-chan types.AsyncLoadResult + type ExecutionEnv struct + Ctx context.Context + Loader AsyncLoadFn + RunBlockHooks func(p peer.ID, response graphsync.ResponseData, blk graphsync.BlockData) error + SendRequest func(peer.ID, gsmsg.GraphSyncRequest) + TerminateRequest func(graphsync.RequestID) + WaitForMessages func(ctx context.Context, resumeMessages chan graphsync.ExtensionData) ([]graphsync.ExtensionData, error) + func (ee ExecutionEnv) Start(re RequestExecution) (chan graphsync.ResponseProgress, chan error) + type RequestExecution struct + Ctx context.Context + DoNotSendCids *cid.Set + LastResponse *atomic.Value + NetworkError chan error + NodePrototypeChooser traversal.LinkTargetNodePrototypeChooser + P peer.ID + PauseMessages chan struct{} + Request gsmsg.GraphSyncRequest + ResumeMessages chan []graphsync.ExtensionData
Go to main page