Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + type PeerMessageHandler interface + AllocateAndBuildMessage func(p peer.ID, blkSize uint64, buildResponseFn func(*gsmsg.Builder), ...) + type ResponseAssembler struct + func New(ctx context.Context, peerHandler PeerMessageHandler) *ResponseAssembler + func (ra *ResponseAssembler) DedupKey(p peer.ID, requestID graphsync.RequestID, key string) + func (ra *ResponseAssembler) IgnoreBlocks(p peer.ID, requestID graphsync.RequestID, links []ld.Link) + func (ra *ResponseAssembler) Transaction(p peer.ID, requestID graphsync.RequestID, transaction Transaction) error + type ResponseBuilder interface + AddNotifee func(notifications.Notifee) + ClearRequest func() + FinishRequest func() graphsync.ResponseStatusCode + FinishWithError func(status graphsync.ResponseStatusCode) + PauseRequest func() + SendExtensionData func(graphsync.ExtensionData) + SendResponse func(link ld.Link, data []byte) graphsync.BlockData + type Transaction func(ResponseBuilder) error
Go to main page