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 + const AdditionalPeers + const ExtensionDeDupByKey + const ExtensionDoNotSendCIDs + const ExtensionsDoNotSendFirstBlocks + const LinkActionDuplicateDAGSkipped + const LinkActionDuplicateNotSent + const LinkActionMissing + const LinkActionPresent + 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 + const RequestTypeCancel + const RequestTypeNew + const RequestTypeUpdate + var ErrExtensionAlreadyRegistered = errors.New("extension already registered") + var ResponseCodeToName = map[ResponseStatusCode]string + type BlockData interface + BlockSize func() uint64 + BlockSizeOnWire func() uint64 + Index func() int64 + Link func() ipld.Link + type ExtensionData struct + Data datamodel.Node + Name ExtensionName + type ExtensionName string + type GraphExchange interface + Cancel func(context.Context, RequestID) error + Pause func(context.Context, RequestID) error + RegisterBlockSentListener func(listener OnBlockSentListener) UnregisterHookFunc + RegisterCompletedResponseListener func(listener OnResponseCompletedListener) UnregisterHookFunc + RegisterIncomingBlockHook func(OnIncomingBlockHook) UnregisterHookFunc + RegisterIncomingRequestHook func(hook OnIncomingRequestHook) UnregisterHookFunc + RegisterIncomingRequestProcessingListener func(listener OnRequestProcessingListener) UnregisterHookFunc + RegisterIncomingResponseHook func(OnIncomingResponseHook) UnregisterHookFunc + RegisterNetworkErrorListener func(listener OnNetworkErrorListener) UnregisterHookFunc + RegisterOutgoingBlockHook func(hook OnOutgoingBlockHook) UnregisterHookFunc + RegisterOutgoingRequestHook func(hook OnOutgoingRequestHook) UnregisterHookFunc + RegisterOutgoingRequestProcessingListener func(listener OnRequestProcessingListener) UnregisterHookFunc + RegisterPersistenceOption func(name string, lsys ipld.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 ipld.Link, selector ipld.Node, ...) (<-chan ResponseProgress, <-chan error) + SendUpdate func(context.Context, RequestID, ...ExtensionData) error + Stats func() Stats + Unpause func(context.Context, RequestID, ...ExtensionData) error + UnregisterPersistenceOption func(name string) error + type IncomingBlockHookActions interface + PauseRequest func() + TerminateWithError func(error) + UpdateRequestWithExtensions func(...ExtensionData) + type IncomingRequestHookActions interface + AugmentContext func(func(reqCtx context.Context) context.Context) + MaxLinks func(uint64) + 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 LinkAction string + func (l LinkAction) DidFollowLink() bool + type LinkMetadata interface + Iterate func(LinkMetadataIterator) + Length func() int64 + type LinkMetadataIterator func(cid.Cid, LinkAction) + 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 OnRequestProcessingListener func(p peer.ID, request RequestData, inProgressRequestCount int) + 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 + MaxLinks func(uint64) + UseLinkTargetNodePrototypeChooser func(traversal.LinkTargetNodePrototypeChooser) + UsePersistenceOption func(name string) + type Priority int32 + type RemoteIncorrectResponseError struct + LocalLink ipld.Link + Path ipld.Path + RemoteLink ipld.Link + func (e RemoteIncorrectResponseError) Error() string + type RemoteMissingBlockErr struct + Link ipld.Link + Path ipld.Path + func (e RemoteMissingBlockErr) Error() string + type RequestCancelledErr struct + func (e RequestCancelledErr) Error() string + type RequestClientCancelledErr struct + func (e RequestClientCancelledErr) Error() string + type RequestData interface + Extension func(name ExtensionName) (datamodel.Node, bool) + ID func() RequestID + Priority func() Priority + Root func() cid.Cid + Selector func() ipld.Node + Type func() RequestType + 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 struct + func NewRequestID() RequestID + func ParseRequestID(b []byte) (RequestID, error) + func (r RequestID) Bytes() []byte + func (r RequestID) String() string + func (r RequestID) Tag() string + type RequestIDContextKey struct + type RequestNotFoundErr struct + func (e RequestNotFoundErr) Error() string + type RequestState uint64 + const CompletingSend + const Paused + const Queued + const Running + func (rs RequestState) String() string + type RequestStates map[RequestID]RequestState + type RequestStats struct + Active uint64 + Pending uint64 + TotalPeers uint64 + type RequestType string + type RequestUpdatedHookActions interface + SendExtensionData func(ExtensionData) + TerminateWithError func(error) + UnpauseResponse func() + type ResponseData interface + Extension func(name ExtensionName) (datamodel.Node, bool) + Metadata func() LinkMetadata + RequestID func() RequestID + Status func() ResponseStatusCode + type ResponseProgress struct + LastBlock struct{ ... } + Node ipld.Node + Path ipld.Path + type ResponseStats struct + MaxAllowedAllocatedPerPeer uint64 + MaxAllowedAllocatedTotal uint64 + NumPeersWithPendingAllocations uint64 + TotalAllocatedAllPeers uint64 + TotalPendingAllocations uint64 + type ResponseStatusCode int32 + func (c ResponseStatusCode) AsError() error + func (c ResponseStatusCode) IsFailure() bool + func (c ResponseStatusCode) IsSuccess() bool + func (c ResponseStatusCode) IsTerminal() bool + func (c ResponseStatusCode) String() string + type Stats struct + IncomingRequests RequestStats + IncomingResponses ResponseStats + OutgoingRequests RequestStats + OutgoingResponses ResponseStats + type UnregisterHookFunc func()
Go to main page