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 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 RequestCloser interface + CloseWithNetworkError func(requestID graphsync.RequestID) + TerminateRequest func(requestID graphsync.RequestID) + type RequestHooks interface + ProcessRequestHooks func(p peer.ID, request graphsync.RequestData, ctx context.Context) hooks.RequestResult + type RequestProcessingListeners interface + NotifyRequestProcessingListeners func(p peer.ID, request graphsync.RequestData, inProgressRequestCount int) + type ResponseAssembler interface + NewStream func(ctx context.Context, p peer.ID, requestID graphsync.RequestID, ...) responseassembler.ResponseStream + type ResponseManager struct + func New(ctx context.Context, linkSystem ipld.LinkSystem, ...) *ResponseManager + func (rm *ResponseManager) CancelResponse(ctx context.Context, requestID graphsync.RequestID) error + func (rm *ResponseManager) CloseWithNetworkError(requestID graphsync.RequestID) + func (rm *ResponseManager) FinishTask(task *peertask.Task, p peer.ID, err error) + func (rm *ResponseManager) GetUpdates(requestID graphsync.RequestID, updatesChan chan<- []gsmsg.GraphSyncRequest) + func (rm *ResponseManager) PauseResponse(ctx context.Context, requestID graphsync.RequestID) error + func (rm *ResponseManager) PeerState(p peer.ID) peerstate.PeerState + func (rm *ResponseManager) ProcessRequests(ctx context.Context, p peer.ID, requests []gsmsg.GraphSyncRequest) + func (rm *ResponseManager) Shutdown() + func (rm *ResponseManager) StartTask(task *peertask.Task, p peer.ID, ...) + func (rm *ResponseManager) Startup() + func (rm *ResponseManager) TerminateRequest(requestID graphsync.RequestID) + func (rm *ResponseManager) UnpauseResponse(ctx context.Context, requestID graphsync.RequestID, ...) error + func (rm *ResponseManager) UpdateResponse(ctx context.Context, requestID graphsync.RequestID, ...) error + type UpdateHooks interface + ProcessUpdateHooks func(p peer.ID, request graphsync.RequestData, update graphsync.RequestData) hooks.UpdateResult
Go to main page