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 PeerHandler interface + AllocateAndBuildMessage func(p peer.ID, blkSize uint64, buildMessageFn func(*messagequeue.Builder)) + type PersistenceOptions interface + GetLinkSystem func(name string) (ipld.LinkSystem, bool) + type RequestHooks interface + ProcessRequestHooks func(p peer.ID, request graphsync.RequestData) hooks.RequestResult + type RequestManager struct + func New(ctx context.Context, persistenceOptions PersistenceOptions, ...) *RequestManager + func (rm *RequestManager) CancelRequest(ctx context.Context, requestID graphsync.RequestID) error + func (rm *RequestManager) Disconnected(p peer.ID) + func (rm *RequestManager) GetRequestTask(p peer.ID, task *peertask.Task, requestExecutionChan chan executor.RequestTask) + func (rm *RequestManager) NewRequest(ctx context.Context, p peer.ID, root ipld.Link, selectorNode ipld.Node, ...) (<-chan graphsync.ResponseProgress, <-chan error) + func (rm *RequestManager) PauseRequest(ctx context.Context, requestID graphsync.RequestID) error + func (rm *RequestManager) PeerState(p peer.ID) peerstate.PeerState + func (rm *RequestManager) ProcessResponses(p peer.ID, responses []gsmsg.GraphSyncResponse, blks []blocks.Block) + func (rm *RequestManager) ReleaseRequestTask(p peer.ID, task *peertask.Task, err error) + func (rm *RequestManager) SendRequest(p peer.ID, request gsmsg.GraphSyncRequest) + func (rm *RequestManager) SetDelegate(peerHandler PeerHandler) + func (rm *RequestManager) Shutdown() + func (rm *RequestManager) Startup() + func (rm *RequestManager) UnpauseRequest(ctx context.Context, requestID graphsync.RequestID, ...) error + func (rm *RequestManager) UpdateRequest(ctx context.Context, requestID graphsync.RequestID, ...) error + type ResponseHooks interface + ProcessResponseHooks func(p peer.ID, response graphsync.ResponseData) hooks.UpdateResult
Go to main page