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 + const ErrCancelledByCommand + const ErrFirstBlockLoad + const ErrNetworkError + type BlockHooks interface + ProcessBlockHooks func(p peer.ID, request graphsync.RequestData, blockData graphsync.BlockData) hooks.BlockResult + type Manager interface + FinishTask func(task *peertask.Task, p peer.ID, err error) + GetUpdates func(requestID graphsync.RequestID, updatesChan chan<- []gsmsg.GraphSyncRequest) + StartTask func(task *peertask.Task, p peer.ID, responseTaskChan chan<- ResponseTask) + type QueryExecutor struct + func New(ctx context.Context, manager Manager, blockHooks BlockHooks, ...) *QueryExecutor + func (qe *QueryExecutor) ExecuteTask(_ context.Context, pid peer.ID, task *peertask.Task) bool + type ResponseSignals struct + ErrSignal chan error + PauseSignal chan struct{} + UpdateSignal chan struct{} + type ResponseStream interface + ClearRequest func() + Transaction func(transaction responseassembler.Transaction) error + type ResponseTask struct + Ctx context.Context + Empty bool + Loader ipld.BlockReadOpener + Request gsmsg.GraphSyncRequest + ResponseStream ResponseStream + Signals ResponseSignals + Span trace.Span + Traverser ipldutil.Traverser + type UpdateHooks interface + ProcessUpdateHooks func(p peer.ID, request graphsync.RequestData, update graphsync.RequestData) hooks.UpdateResult
Go to main page