Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + type BlockHooks interface + ProcessBlockHooks func(p peer.ID, request graphsync.RequestData, blockData graphsync.BlockData) hooks.BlockResult + type BlockSentListeners interface + NotifyBlockSentListeners func(p peer.ID, request graphsync.RequestData, block graphsync.BlockData) + type CancelledListeners interface + NotifyCancelledListeners func(p peer.ID, request graphsync.RequestData) + type CompletedListeners interface + NotifyCompletedListeners func(p peer.ID, request graphsync.RequestData, status graphsync.ResponseStatusCode) + type NetworkErrorListeners interface + NotifyNetworkErrorListeners func(p peer.ID, request graphsync.RequestData, err error) + type QueryQueue interface + PopTasks func(targetMinWork int) (peer.ID, []*peertask.Task, int) + PushTasks func(to peer.ID, tasks ...peertask.Task) + Remove func(topic peertask.Topic, p peer.ID) + TasksDone func(to peer.ID, tasks ...*peertask.Task) + ThawRound func() + type RequestHooks interface + ProcessRequestHooks func(p peer.ID, request graphsync.RequestData) hooks.RequestResult + type ResponseAssembler interface + DedupKey func(p peer.ID, requestID graphsync.RequestID, key string) + IgnoreBlocks func(p peer.ID, requestID graphsync.RequestID, links []ld.Link) + Transaction func(p peer.ID, requestID graphsync.RequestID, ...) error + type ResponseManager struct + func New(ctx context.Context, linkSystem ld.LinkSystem, ...) *ResponseManager + func (rm *ResponseManager) CancelResponse(p peer.ID, requestID graphsync.RequestID) error + func (rm *ResponseManager) PauseResponse(p peer.ID, requestID graphsync.RequestID) error + func (rm *ResponseManager) ProcessRequests(ctx context.Context, p peer.ID, requests []gsmsg.GraphSyncRequest) + func (rm *ResponseManager) Shutdown() + func (rm *ResponseManager) Startup() + func (rm *ResponseManager) UnpauseResponse(p peer.ID, requestID graphsync.RequestID, ...) error + type UpdateHooks interface + ProcessUpdateHooks func(p peer.ID, request graphsync.RequestData, update graphsync.RequestData) hooks.UpdateResult
Go to main page