Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + func IsTerminalFailureCode(status graphsync.ResponseStatusCode) bool + func IsTerminalResponseCode(status graphsync.ResponseStatusCode) bool + func IsTerminalSuccessCode(status graphsync.ResponseStatusCode) bool + type Builder struct + func NewBuilder(topic Topic) *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 ld.Link, blockPresent bool) + 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) Topic() Topic + type Exportable interface + ToNet func(w io.Writer) error + ToProto func() (*pb.Message, error) + type GraphSyncMessage struct + func FromMsgReader(r msgio.Reader) (GraphSyncMessage, error) + func FromNet(r io.Reader) (GraphSyncMessage, error) + func (gsm GraphSyncMessage) Blocks() []blocks.Block + func (gsm GraphSyncMessage) Clone() GraphSyncMessage + func (gsm GraphSyncMessage) Empty() bool + func (gsm GraphSyncMessage) Loggable() map[string]interface{} + func (gsm GraphSyncMessage) Requests() []GraphSyncRequest + func (gsm GraphSyncMessage) Responses() []GraphSyncResponse + func (gsm GraphSyncMessage) ToNet(w io.Writer) error + func (gsm GraphSyncMessage) ToProto() (*pb.Message, error) + type GraphSyncRequest struct + func CancelRequest(id graphsync.RequestID) GraphSyncRequest + func NewRequest(id graphsync.RequestID, root cid.Cid, selector ld.Node, ...) GraphSyncRequest + func UpdateRequest(id graphsync.RequestID, extensions ...graphsync.ExtensionData) GraphSyncRequest + func (gsr GraphSyncRequest) Extension(name graphsync.ExtensionName) ([]byte, bool) + func (gsr GraphSyncRequest) ID() graphsync.RequestID + func (gsr GraphSyncRequest) IsCancel() bool + func (gsr GraphSyncRequest) IsUpdate() bool + 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() ld.Node + type GraphSyncResponse struct + func NewResponse(requestID graphsync.RequestID, status graphsync.ResponseStatusCode, ...) GraphSyncResponse + func (gsr GraphSyncResponse) Extension(name graphsync.ExtensionName) ([]byte, bool) + func (gsr GraphSyncResponse) RequestID() graphsync.RequestID + func (gsr GraphSyncResponse) Status() graphsync.ResponseStatusCode + type Topic uint64
Go to main page