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 Allocator interface + AllocateBlockMemory func(p peer.ID, amount uint64) <-chan error + ReleaseBlockMemory func(p peer.ID, amount uint64) error + ReleasePeerMemory func(p peer.ID) error + type Builder struct + func NewBuilder(ctx context.Context, topic Topic) *Builder + func (b *Builder) AddBlockData(requestID graphsync.RequestID, blockData graphsync.BlockData) + func (b *Builder) BlockData() map[graphsync.RequestID][]graphsync.BlockData + func (b *Builder) Context() context.Context + func (b *Builder) ResponseStreams() map[graphsync.RequestID]io.Closer + func (b *Builder) ScrubResponses(requestIDs []graphsync.RequestID) uint64 + func (b *Builder) SetResponseStream(requestID graphsync.RequestID, stream io.Closer) + func (b *Builder) SetSubscriber(requestID graphsync.RequestID, subscriber notifications.Subscriber) + func (b *Builder) Subscribers() map[graphsync.RequestID]notifications.Subscriber + type Event struct + Err error + Metadata Metadata + Name EventName + type EventName uint64 + const Error + const Queued + const Sent + type MessageNetwork interface + ConnectTo func(context.Context, peer.ID) error + NewMessageSender func(context.Context, peer.ID, gsnet.MessageSenderOpts) (gsnet.MessageSender, error) + type MessageQueue struct + func New(ctx context.Context, p peer.ID, network MessageNetwork, allocator Allocator, ...) *MessageQueue + func (mq *MessageQueue) AllocateAndBuildMessage(size uint64, buildMessageFn func(*Builder)) + func (mq *MessageQueue) Shutdown() + func (mq *MessageQueue) Startup() + type Metadata struct + BlockData map[graphsync.RequestID][]graphsync.BlockData + ResponseCodes map[graphsync.RequestID]graphsync.ResponseStatusCode + type Topic uint64