queryexecutor

Dec 17, 2021

Changes in this version

+ type ResponseStream interface

+ ClearRequest func()

+ Transaction func(transaction responseassembler.Transaction) error

type ResponseTask

+ ResponseStream ResponseStream

Dec 11, 2021

Changes in this version

type ResponseTask

+ Span trace.Span

Nov 29, 2021

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 CancelledListeners interface

+ NotifyCancelledListeners func(p peer.ID, request graphsync.RequestData)

+ type Manager interface

+ FinishTask func(task *peertask.Task, err error)

+ GetUpdates func(p peer.ID, requestID graphsync.RequestID, ...)

+ StartTask func(task *peertask.Task, responseTaskChan chan<- ResponseTask)

+ type QueryExecutor struct

+ func New(ctx context.Context, manager Manager, blockHooks BlockHooks, ...) *QueryExecutor

+ func (qe *QueryExecutor) ExecuteTask(ctx context.Context, pid peer.ID, task *peertask.Task) bool

+ type ResponseAssembler interface

+ Transaction func(p peer.ID, requestID graphsync.RequestID, ...) error

+ type ResponseSignals struct

+ ErrSignal chan error

+ PauseSignal chan struct{}

+ UpdateSignal chan struct{}

+ type ResponseTask struct

+ Ctx context.Context

+ Empty bool

+ Loader ipld.BlockReadOpener

+ Request gsmsg.GraphSyncRequest

+ Signals ResponseSignals

+ Subscriber *notifications.TopicDataSubscriber

+ Traverser ipldutil.Traverser

+ type UpdateHooks interface

+ ProcessUpdateHooks func(p peer.ID, request graphsync.RequestData, update graphsync.RequestData) hooks.UpdateResult