Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + type AsyncLoader interface + AsyncLoad func(requestID graphsync.RequestID, link ld.Link) <-chan types.AsyncLoadResult + CleanupRequest func(requestID graphsync.RequestID) + CompleteResponsesFor func(requestID graphsync.RequestID) + ProcessResponse func(responses map[graphsync.RequestID]metadata.Metadata, blks []blocks.Block) + StartRequest func(graphsync.RequestID, string) error + type BlockHooks interface + ProcessBlockHooks func(p peer.ID, response graphsync.ResponseData, block graphsync.BlockData) hooks.UpdateResult + type PeerHandler interface + AllocateAndBuildMessage func(p peer.ID, blkSize uint64, buildMessageFn func(*gsmsg.Builder), ...) + type RequestHooks interface + ProcessRequestHooks func(p peer.ID, request graphsync.RequestData) hooks.RequestResult + type RequestManager struct + func New(ctx context.Context, asyncLoader AsyncLoader, requestHooks RequestHooks, ...) *RequestManager + func (rm *RequestManager) PauseRequest(requestID graphsync.RequestID) error + func (rm *RequestManager) ProcessResponses(p peer.ID, responses []gsmsg.GraphSyncResponse, blks []blocks.Block) + func (rm *RequestManager) SendRequest(ctx context.Context, p peer.ID, root ld.Link, selector ld.Node, ...) (<-chan graphsync.ResponseProgress, <-chan error) + func (rm *RequestManager) SetDelegate(peerHandler PeerHandler) + func (rm *RequestManager) Shutdown() + func (rm *RequestManager) Startup() + func (rm *RequestManager) UnpauseRequest(requestID graphsync.RequestID, extensions ...graphsync.ExtensionData) error + type ResponseHooks interface + ProcessResponseHooks func(p peer.ID, response graphsync.ResponseData) hooks.UpdateResult
Go to main page