Versions in this module Expand all Collapse all v0 v0.16.2 Dec 14, 2023 v0.16.1 Dec 14, 2023 Changes in this version + type BlockHooks interface + ProcessBlockHooks func(p peer.ID, response graphsync.ResponseData, block graphsync.BlockData) hooks.UpdateResult + type Executor struct + func NewExecutor(manager Manager, blockHooks BlockHooks) *Executor + func (e *Executor) ExecuteTask(ctx context.Context, pid peer.ID, task *peertask.Task) bool + type Manager interface + GetRequestTask func(peer.ID, *peertask.Task, chan RequestTask) + ReleaseRequestTask func(peer.ID, *peertask.Task, error) + SendRequest func(peer.ID, gsmsg.GraphSyncRequest) + type ReconciledLoader interface + BlockReadOpener func(lctx linking.LinkContext, link datamodel.Link) types.AsyncLoadResult + RetryLastLoad func() types.AsyncLoadResult + SetRemoteOnline func(online bool) + type RequestTask struct + Ctx context.Context + DoNotSendFirstBlocks int64 + Empty bool + InProgressErr chan error + LastResponse *atomic.Value + P peer.ID + PauseMessages <-chan struct{} + ReconciledLoader ReconciledLoader + Request gsmsg.GraphSyncRequest + Span trace.Span + Traverser ipldutil.Traverser
Go to main page