graphsync

Apr 22, 2023

Changes in this version

type IncomingRequestHookActions

+ MaxLinks func(uint64)

type OutgoingRequestHookActions

+ MaxLinks func(uint64)

Oct 6, 2022

Changes in this version

type GraphExchange

+ RegisterIncomingRequestProcessingListener func(listener OnRequestProcessingListener) UnregisterHookFunc

type IncomingRequestHookActions

+ AugmentContext func(func(reqCtx context.Context) context.Context)

+ type OnRequestProcessingListener func(p peer.ID, request RequestData, inProgressRequestCount int)

Jun 23, 2022

Changes in this version

+ type RequestIDContextKey struct

Mar 9, 2022

Changes in this version

+ const LinkActionDuplicateDAGSkipped

+ const LinkActionDuplicateNotSent

+ const LinkActionMissing

+ const LinkActionPresent

+ const RequestTypeCancel

+ const RequestTypeNew

+ const RequestTypeUpdate

type GraphExchange

+ Cancel func(context.Context, RequestID) error

+ Pause func(context.Context, RequestID) error

+ SendUpdate func(context.Context, RequestID, ...ExtensionData) error

+ Unpause func(context.Context, RequestID, ...ExtensionData) error

+ type LinkAction string

+ func (l LinkAction) DidFollowLink() bool

+ type LinkMetadata interface

+ Iterate func(LinkMetadataIterator)

+ Length func() int64

+ type LinkMetadataIterator func(cid.Cid, LinkAction)

+ type RemoteIncorrectResponseError struct

+ LocalLink ipld.Link

+ Path ipld.Path

+ RemoteLink ipld.Link

+ func (e RemoteIncorrectResponseError) Error() string

type RemoteMissingBlockErr

+ Path ipld.Path

type RequestData

+ Type func() RequestType

type RequestID

+ func NewRequestID() RequestID

+ func ParseRequestID(b []byte) (RequestID, error)

+ func (r RequestID) Bytes() []byte

+ func (r RequestID) String() string

+ type RequestType string

type ResponseData

+ Metadata func() LinkMetadata

Dec 17, 2021

Changes in this version

+ type RequestQueuedHookActions interface

+ AugmentContext func(func(reqCtx context.Context) context.Context)

Dec 9, 2021

Changes in this version

type RequestState

+ const CompletingSend

Dec 9, 2021

Changes in this version

+ type RequestState uint64

+ const Paused

+ const Queued

+ const Running

+ func (rs RequestState) String() string

+ type RequestStates map[RequestID]RequestState

Nov 2, 2021

Changes in this version

type GraphExchange

+ RegisterOutgoingRequestProcessingListener func(listener OnOutgoingRequestProcessingListener) UnregisterHookFunc

+ type OnOutgoingRequestProcessingListener func(p peer.ID, request RequestData, inProgressRequestCount int)

Oct 13, 2021

Changes in this version

type GraphExchange

+ Stats func() Stats

+ type RequestStats struct

+ Active uint64

+ Pending uint64

+ TotalPeers uint64

+ type ResponseStats struct

+ MaxAllowedAllocatedPerPeer uint64

+ MaxAllowedAllocatedTotal uint64

+ NumPeersWithPendingAllocations uint64

+ TotalAllocatedAllPeers uint64

+ TotalPendingAllocations uint64

+ type Stats struct

+ IncomingRequests RequestStats

+ IncomingResponses ResponseStats

+ OutgoingRequests RequestStats

+ OutgoingResponses ResponseStats

Oct 5, 2021

Changes in this version

+ const ExtensionsDoNotSendFirstBlocks

type BlockData

+ Index func() int64

+ type RemoteMissingBlockErr struct

+ Link ipld.Link

+ func (e RemoteMissingBlockErr) Error() string

type RequestID

+ func (r RequestID) Tag() string

type ResponseStatusCode

+ func (c ResponseStatusCode) AsError() error

+ func (c ResponseStatusCode) IsFailure() bool

+ func (c ResponseStatusCode) IsSuccess() bool

+ func (c ResponseStatusCode) IsTerminal() bool

Mar 26, 2021

Changes in this version

+ var ResponseCodeToName = map[ResponseStatusCode]string

type ResponseStatusCode

+ func (c ResponseStatusCode) String() string

Aug 23, 2021

Changes in this version

type GraphExchange

+ CancelRequest func(context.Context, RequestID) error

+ type RequestClientCancelledErr struct

+ func (e RequestClientCancelledErr) Error() string

+ type RequestNotFoundErr struct

+ func (e RequestNotFoundErr) Error() string

Jun 9, 2021

Changes in this version

type GraphExchange

+ RegisterIncomingRequestQueuedHook func(hook OnIncomingRequestQueuedHook) UnregisterHookFunc

+ type OnIncomingRequestQueuedHook func(p peer.ID, request RequestData)

Jan 21, 2021

Changes in this version

type GraphExchange

+ RegisterReceiverNetworkErrorListener func(listener OnReceiverNetworkErrorListener) UnregisterHookFunc

+ type OnReceiverNetworkErrorListener func(p peer.ID, err error)

Oct 14, 2020

Changes in this version

type GraphExchange

+ RegisterBlockSentListener func(listener OnBlockSentListener) UnregisterHookFunc

+ RegisterNetworkErrorListener func(listener OnNetworkErrorListener) UnregisterHookFunc

+ type OnBlockSentListener func(p peer.ID, request RequestData, block BlockData)

+ type OnNetworkErrorListener func(p peer.ID, request RequestData, err error)

Sep 23, 2020

Changes in this version

type IncomingRequestHookActions

+ UseLinkTargetNodePrototypeChooser func(traversal.LinkTargetNodePrototypeChooser)

type OutgoingRequestHookActions

+ UseLinkTargetNodePrototypeChooser func(traversal.LinkTargetNodePrototypeChooser)

+ type RequestContextCancelledErr struct

+ func (e RequestContextCancelledErr) Error() string

Aug 13, 2020

Changes in this version

+ const ExtensionDeDupByKey

Aug 4, 2020

Changes in this version

+ const RequestCancelled

+ const RequestPaused

+ type BlockData interface

+ BlockSize func() uint64

+ BlockSizeOnWire func() uint64

+ Link func() ipld.Link

type GraphExchange

+ CancelResponse func(peer.ID, RequestID) error

+ PauseRequest func(RequestID) error

+ PauseResponse func(peer.ID, RequestID) error

+ RegisterCompletedResponseListener func(listener OnResponseCompletedListener) UnregisterHookFunc

+ RegisterIncomingBlockHook func(OnIncomingBlockHook) UnregisterHookFunc

+ RegisterIncomingRequestHook func(hook OnIncomingRequestHook) UnregisterHookFunc

+ RegisterIncomingResponseHook func(OnIncomingResponseHook) UnregisterHookFunc

+ RegisterOutgoingBlockHook func(hook OnOutgoingBlockHook) UnregisterHookFunc

+ RegisterOutgoingRequestHook func(hook OnOutgoingRequestHook) UnregisterHookFunc

+ RegisterPersistenceOption func(name string, loader ipld.Loader, storer ipld.Storer) error

+ RegisterRequestUpdatedHook func(hook OnRequestUpdatedHook) UnregisterHookFunc

+ RegisterRequestorCancelledListener func(listener OnRequestorCancelledListener) UnregisterHookFunc

+ 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)

+ UseLinkTargetNodeStyleChooser func(traversal.LinkTargetNodeStyleChooser)

+ UsePersistenceOption func(name string)

+ ValidateRequest func()

+ type IncomingResponseHookActions interface

+ TerminateWithError func(error)

+ UpdateRequestWithExtensions func(...ExtensionData)

+ 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 OnOutgoingBlockHook func(p peer.ID, request RequestData, block BlockData, ...)

+ type OnOutgoingRequestHook func(p peer.ID, request RequestData, hookActions OutgoingRequestHookActions)

+ 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

+ UseLinkTargetNodeStyleChooser func(traversal.LinkTargetNodeStyleChooser)

+ UsePersistenceOption func(name string)

+ type RequestCancelledErr struct

+ func (e RequestCancelledErr) Error() string

+ 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 RequestUpdatedHookActions interface

+ SendExtensionData func(ExtensionData)

+ TerminateWithError func(error)

+ UnpauseResponse func()

+ type UnregisterHookFunc func()

Dec 3, 2019

Changes in this version

+ const AdditionalPeers

+ const ExtensionDoNotSendCIDs

+ const ExtensionMetadata

+ const NotEnoughGas

+ const OtherProtocol

+ const PartialResponse

+ const RequestAcknowledged

+ const RequestCompletedFull

+ const RequestCompletedPartial

+ const RequestFailedBusy

+ const RequestFailedContentNotFound

+ const RequestFailedLegal

+ const RequestFailedUnknown

+ const RequestRejected

+ var ErrExtensionAlreadyRegistered = errors.New("extension already registered")

+ type ExtensionData struct

+ Data []byte

+ Name ExtensionName

+ type ExtensionName string

+ type GraphExchange interface

+ RegisterRequestReceivedHook func(hook OnRequestReceivedHook) error

+ RegisterResponseReceivedHook func(OnResponseReceivedHook) error

+ Request func(ctx context.Context, p peer.ID, root ipld.Link, selector ipld.Node, ...) (<-chan ResponseProgress, <-chan error)

+ type OnRequestReceivedHook func(p peer.ID, request RequestData, hookActions RequestReceivedHookActions)

+ type OnResponseReceivedHook func(p peer.ID, responseData ResponseData) error

+ type Priority int32

+ type RequestData interface

+ Extension func(name ExtensionName) ([]byte, bool)

+ ID func() RequestID

+ IsCancel func() bool

+ Priority func() Priority

+ Root func() cid.Cid

+ Selector func() []byte

+ type RequestID int32

+ type RequestReceivedHookActions interface

+ SendExtensionData func(ExtensionData)

+ TerminateWithError func(error)

+ ValidateRequest func()

+ type ResponseData interface

+ Extension func(name ExtensionName) ([]byte, bool)

+ RequestID func() RequestID

+ Status func() ResponseStatusCode

type ResponseProgress

+ LastBlock struct{ ... }

+ Node ipld.Node

+ Path ipld.Path

+ type ResponseStatusCode int32

Sep 3, 2019

Changes in this version

+ type GraphSync struct

+ func New(parent context.Context, network gsnet.GraphSyncNetwork, ...) *GraphSync

+ func (gs *GraphSync) Request(ctx context.Context, p peer.ID, root ipld.Link, selector ipld.Node) (<-chan ResponseProgress, <-chan error)

+ type ResponseProgress = types.ResponseProgress