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 PeerMessageHandler interface + AllocateAndBuildMessage func(p peer.ID, blkSize uint64, buildResponseFn func(*messagequeue.Builder)) + type ResponseAssembler struct + func New(ctx context.Context, peerHandler PeerMessageHandler) *ResponseAssembler + func (ra *ResponseAssembler) NewStream(ctx context.Context, p peer.ID, requestID graphsync.RequestID, ...) ResponseStream + type ResponseBuilder interface + Context func() context.Context + FinishRequest func() graphsync.ResponseStatusCode + FinishWithError func(status graphsync.ResponseStatusCode) + PauseRequest func() + SendExtensionData func(graphsync.ExtensionData) + SendResponse func(link ipld.Link, data []byte) graphsync.BlockData + SendUpdates func([]graphsync.ExtensionData) + type ResponseStream interface + ClearRequest func() + DedupKey func(key string) + IgnoreBlocks func(links []ipld.Link) + SkipFirstBlocks func(skipFirstBlocks int64) + Transaction func(transaction Transaction) error + type Transaction func(ResponseBuilder) error
Go to main page