Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + const AdditionalPeers + const ExtensionDeDupByKey + const ExtensionDoNotSendCIDs + const ExtensionMetadata + const NotEnoughGas + const OtherProtocol + const PartialResponse + const RequestAcknowledged + const RequestCancelled + const RequestCompletedFull + const RequestCompletedPartial + const RequestFailedBusy + const RequestFailedContentNotFound + const RequestFailedLegal + const RequestFailedUnknown + const RequestPaused + const RequestRejected + var ErrExtensionAlreadyRegistered = errors.New("extension already registered") + var ResponseCodeToName = map[ResponseStatusCode]string + type BlockData interface + BlockSize func() uint64 + BlockSizeOnWire func() uint64 + Link func() ld.Link + type ExtensionData struct + Data []byte + Name ExtensionName + type ExtensionName string + type GraphExchange interface + CancelResponse func(peer.ID, RequestID) error + PauseRequest func(RequestID) error + PauseResponse func(peer.ID, RequestID) error + RegisterBlockSentListener func(listener OnBlockSentListener) UnregisterHookFunc + RegisterCompletedResponseListener func(listener OnResponseCompletedListener) UnregisterHookFunc + RegisterIncomingBlockHook func(OnIncomingBlockHook) UnregisterHookFunc + RegisterIncomingRequestHook func(hook OnIncomingRequestHook) UnregisterHookFunc + RegisterIncomingResponseHook func(OnIncomingResponseHook) UnregisterHookFunc + RegisterNetworkErrorListener func(listener OnNetworkErrorListener) UnregisterHookFunc + RegisterOutgoingBlockHook func(hook OnOutgoingBlockHook) UnregisterHookFunc + RegisterOutgoingRequestHook func(hook OnOutgoingRequestHook) UnregisterHookFunc + RegisterPersistenceOption func(name string, lsys ld.LinkSystem) error + RegisterReceiverNetworkErrorListener func(listener OnReceiverNetworkErrorListener) UnregisterHookFunc + RegisterRequestUpdatedHook func(hook OnRequestUpdatedHook) UnregisterHookFunc + RegisterRequestorCancelledListener func(listener OnRequestorCancelledListener) UnregisterHookFunc + Request func(ctx context.Context, p peer.ID, root ld.Link, selector ld.Node, ...) (<-chan ResponseProgress, <-chan error) + UnpauseRequest func(RequestID, ...ExtensionData) error + UnpauseResponse func(peer.ID, RequestID, ...ExtensionData) error + UnregisterPersistenceOption func(name string) error + type IncomingBlockHookActions interface + PauseRequest func() + TerminateWithError func(error) + UpdateRequestWithExtensions func(...ExtensionData) + type IncomingRequestHookActions interface + PauseResponse func() + SendExtensionData func(ExtensionData) + TerminateWithError func(error) + UseLinkTargetNodePrototypeChooser func(traversal.LinkTargetNodePrototypeChooser) + UsePersistenceOption func(name string) + ValidateRequest func() + type IncomingResponseHookActions interface + TerminateWithError func(error) + UpdateRequestWithExtensions func(...ExtensionData) + type OnBlockSentListener func(p peer.ID, request RequestData, block BlockData) + type OnIncomingBlockHook func(p peer.ID, responseData ResponseData, blockData BlockData, ...) + type OnIncomingRequestHook func(p peer.ID, request RequestData, hookActions IncomingRequestHookActions) + type OnIncomingResponseHook func(p peer.ID, responseData ResponseData, hookActions IncomingResponseHookActions) + type OnNetworkErrorListener func(p peer.ID, request RequestData, err error) + type OnOutgoingBlockHook func(p peer.ID, request RequestData, block BlockData, ...) + type OnOutgoingRequestHook func(p peer.ID, request RequestData, hookActions OutgoingRequestHookActions) + type OnReceiverNetworkErrorListener func(p peer.ID, err error) + type OnRequestUpdatedHook func(p peer.ID, request RequestData, updateRequest RequestData, ...) + type OnRequestorCancelledListener func(p peer.ID, request RequestData) + type OnResponseCompletedListener func(p peer.ID, request RequestData, status ResponseStatusCode) + type OutgoingBlockHookActions interface + PauseResponse func() + SendExtensionData func(ExtensionData) + TerminateWithError func(error) + type OutgoingRequestHookActions interface + UseLinkTargetNodePrototypeChooser func(traversal.LinkTargetNodePrototypeChooser) + UsePersistenceOption func(name string) + type Priority int32 + type RequestCancelledErr struct + func (e RequestCancelledErr) Error() string + type RequestContextCancelledErr struct + func (e RequestContextCancelledErr) Error() string + type RequestData interface + Extension func(name ExtensionName) ([]byte, bool) + ID func() RequestID + IsCancel func() bool + Priority func() Priority + Root func() cid.Cid + Selector func() ld.Node + type RequestFailedBusyErr struct + func (e RequestFailedBusyErr) Error() string + type RequestFailedContentNotFoundErr struct + func (e RequestFailedContentNotFoundErr) Error() string + type RequestFailedLegalErr struct + func (e RequestFailedLegalErr) Error() string + type RequestFailedUnknownErr struct + func (e RequestFailedUnknownErr) Error() string + type RequestID int32 + type RequestUpdatedHookActions interface + SendExtensionData func(ExtensionData) + TerminateWithError func(error) + UnpauseResponse func() + type ResponseData interface + Extension func(name ExtensionName) ([]byte, bool) + RequestID func() RequestID + Status func() ResponseStatusCode + type ResponseProgress struct + LastBlock struct{ ... } + Node ld.Node + Path ld.Path + type ResponseStatusCode int32 + func (c ResponseStatusCode) String() string + type UnregisterHookFunc func()