Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + func New(parent context.Context, network gsnet.GraphSyncNetwork, ...) graphsync.GraphExchange + type GraphSync struct + func (gs *GraphSync) CancelResponse(p peer.ID, requestID graphsync.RequestID) error + func (gs *GraphSync) PauseRequest(requestID graphsync.RequestID) error + func (gs *GraphSync) PauseResponse(p peer.ID, requestID graphsync.RequestID) error + func (gs *GraphSync) RegisterBlockSentListener(listener graphsync.OnBlockSentListener) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterCompletedResponseListener(listener graphsync.OnResponseCompletedListener) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterIncomingBlockHook(hook graphsync.OnIncomingBlockHook) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterIncomingRequestHook(hook graphsync.OnIncomingRequestHook) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterIncomingResponseHook(hook graphsync.OnIncomingResponseHook) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterNetworkErrorListener(listener graphsync.OnNetworkErrorListener) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterOutgoingBlockHook(hook graphsync.OnOutgoingBlockHook) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterOutgoingRequestHook(hook graphsync.OnOutgoingRequestHook) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterPersistenceOption(name string, lsys ld.LinkSystem) error + func (gs *GraphSync) RegisterReceiverNetworkErrorListener(listener graphsync.OnReceiverNetworkErrorListener) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterRequestUpdatedHook(hook graphsync.OnRequestUpdatedHook) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterRequestorCancelledListener(listener graphsync.OnRequestorCancelledListener) graphsync.UnregisterHookFunc + func (gs *GraphSync) Request(ctx context.Context, p peer.ID, root ld.Link, selector ld.Node, ...) (<-chan graphsync.ResponseProgress, <-chan error) + func (gs *GraphSync) UnpauseRequest(requestID graphsync.RequestID, extensions ...graphsync.ExtensionData) error + func (gs *GraphSync) UnpauseResponse(p peer.ID, requestID graphsync.RequestID, ...) error + func (gs *GraphSync) UnregisterPersistenceOption(name string) error + type Option func(*graphsyncConfigOptions) + func MaxInProgressRequests(maxInProgressRequests uint64) Option + func MaxMemoryPerPeerResponder(maxMemoryPerPeer uint64) Option + func MaxMemoryResponder(totalMaxMemory uint64) Option + func RejectAllRequestsByDefault() Option
Go to main page