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 + type Builder struct + func NewBuilder() *Builder + func (b *Builder) AddBlock(block blocks.Block) + func (b *Builder) AddExtensionData(requestID graphsync.RequestID, extension graphsync.ExtensionData) + func (b *Builder) AddLink(requestID graphsync.RequestID, link ipld.Link, linkAction graphsync.LinkAction) + func (b *Builder) AddRequest(request GraphSyncRequest) + func (b *Builder) AddResponseCode(requestID graphsync.RequestID, status graphsync.ResponseStatusCode) + func (b *Builder) BlockSize() uint64 + func (b *Builder) Build() (GraphSyncMessage, error) + func (b *Builder) Empty() bool + func (b *Builder) ScrubResponses(requestIDs []graphsync.RequestID) uint64 + type GraphSyncLinkMetadata struct + func NewLinkMetadata(md []GraphSyncLinkMetadatum) GraphSyncLinkMetadata + func (gslm GraphSyncLinkMetadata) Iterate(iter graphsync.LinkMetadataIterator) + func (gslm GraphSyncLinkMetadata) Length() int64 + func (gslm GraphSyncLinkMetadata) RawMetadata() []GraphSyncLinkMetadatum + type GraphSyncLinkMetadatum struct + Action graphsync.LinkAction + Link cid.Cid + type GraphSyncMessage struct + func NewMessage(requests map[graphsync.RequestID]GraphSyncRequest, ...) GraphSyncMessage + func (gsm GraphSyncMessage) Blocks() []blocks.Block + func (gsm GraphSyncMessage) Clone() GraphSyncMessage + func (gsm GraphSyncMessage) Empty() bool + func (gsm GraphSyncMessage) Requests() []GraphSyncRequest + func (gsm GraphSyncMessage) ResponseCodes() map[graphsync.RequestID]graphsync.ResponseStatusCode + func (gsm GraphSyncMessage) Responses() []GraphSyncResponse + func (gsm GraphSyncMessage) String() string + type GraphSyncRequest struct + func NewCancelRequest(id graphsync.RequestID) GraphSyncRequest + func NewRequest(id graphsync.RequestID, root cid.Cid, selector ipld.Node, ...) GraphSyncRequest + func NewUpdateRequest(id graphsync.RequestID, extensions ...graphsync.ExtensionData) GraphSyncRequest + func (gsr GraphSyncRequest) Extension(name graphsync.ExtensionName) (datamodel.Node, bool) + func (gsr GraphSyncRequest) ExtensionNames() []graphsync.ExtensionName + func (gsr GraphSyncRequest) ID() graphsync.RequestID + func (gsr GraphSyncRequest) MergeExtensions(extensions []graphsync.ExtensionData, ...) (GraphSyncRequest, error) + func (gsr GraphSyncRequest) Priority() graphsync.Priority + func (gsr GraphSyncRequest) ReplaceExtensions(extensions []graphsync.ExtensionData) GraphSyncRequest + func (gsr GraphSyncRequest) Root() cid.Cid + func (gsr GraphSyncRequest) Selector() ipld.Node + func (gsr GraphSyncRequest) String() string + func (gsr GraphSyncRequest) Type() graphsync.RequestType + type GraphSyncResponse struct + func NewResponse(requestID graphsync.RequestID, status graphsync.ResponseStatusCode, ...) GraphSyncResponse + func (gsr GraphSyncResponse) Extension(name graphsync.ExtensionName) (datamodel.Node, bool) + func (gsr GraphSyncResponse) ExtensionNames() []graphsync.ExtensionName + func (gsr GraphSyncResponse) Metadata() graphsync.LinkMetadata + func (gsr GraphSyncResponse) RequestID() graphsync.RequestID + func (gsr GraphSyncResponse) Status() graphsync.ResponseStatusCode + func (gsr GraphSyncResponse) String() string + type MessageHandler interface + FromMsgReader func(peer.ID, msgio.Reader) (GraphSyncMessage, error) + FromNet func(peer.ID, io.Reader) (GraphSyncMessage, error) + ToNet func(peer.ID, GraphSyncMessage, io.Writer) error + type MessagePartWithExtensions interface + Extension func(name graphsync.ExtensionName) (datamodel.Node, bool) + ExtensionNames func() []graphsync.ExtensionName
Go to main page