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 + func New(parent context.Context, network gsnet.GraphSyncNetwork, ...) graphsync.GraphExchange + type GraphSync struct + func (gs *GraphSync) Cancel(ctx context.Context, requestID graphsync.RequestID) error + func (gs *GraphSync) Pause(ctx context.Context, requestID graphsync.RequestID) error + func (gs *GraphSync) PeerState(p peer.ID) PeerState + 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) RegisterIncomingRequestProcessingListener(listener graphsync.OnRequestProcessingListener) 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) RegisterOutgoingRequestProcessingListener(listener graphsync.OnRequestProcessingListener) graphsync.UnregisterHookFunc + func (gs *GraphSync) RegisterPersistenceOption(name string, lsys ipld.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 ipld.Link, selector ipld.Node, ...) (<-chan graphsync.ResponseProgress, <-chan error) + func (gs *GraphSync) SendUpdate(ctx context.Context, requestID graphsync.RequestID, ...) error + func (gs *GraphSync) Stats() graphsync.Stats + func (gs *GraphSync) Unpause(ctx context.Context, requestID graphsync.RequestID, ...) error + func (gs *GraphSync) UnregisterPersistenceOption(name string) error + type Option func(*graphsyncConfigOptions) + func MaxInProgressIncomingRequests(maxInProgressIncomingRequests uint64) Option + func MaxInProgressIncomingRequestsPerPeer(maxInProgressIncomingRequestsPerPeer uint64) Option + func MaxInProgressOutgoingRequests(maxInProgressOutgoingRequests uint64) Option + func MaxLinksPerIncomingRequests(maxLinksPerIncomingRequest uint64) Option + func MaxLinksPerOutgoingRequests(maxLinksPerOutgoingRequest uint64) Option + func MaxMemoryPerPeerResponder(maxMemoryPerPeer uint64) Option + func MaxMemoryResponder(totalMaxMemory uint64) Option + func MessageSendRetries(messageSendRetries int) Option + func PanicCallback(callbackFn panics.CallBackFn) Option + func RejectAllRequestsByDefault() Option + func SendMessageTimeout(sendMessageTimeout time.Duration) Option + type PeerState struct + IncomingState peerstate.PeerState + OutgoingState peerstate.PeerState
Go to main page