Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageNetwork ¶
type MessageNetwork interface { NewMessageSender(context.Context, peer.ID) (gsnet.MessageSender, error) ConnectTo(context.Context, peer.ID) error }
MessageNetwork is any network that can connect peers and generate a message sender.
type MessageQueue ¶
type MessageQueue struct {
// contains filtered or unexported fields
}
MessageQueue implements queue of want messages to send to peers.
func New ¶
func New(ctx context.Context, p peer.ID, network MessageNetwork, allocator Allocator) *MessageQueue
New creats a new MessageQueue.
func (*MessageQueue) AllocateAndBuildMessage ¶ added in v0.6.0
func (mq *MessageQueue) AllocateAndBuildMessage(size uint64, buildMessageFn func(*gsmsg.Builder), notifees []notifications.Notifee)
AllocateAndBuildMessage allows you to work modify the next message that is sent in the queue. If blkSize > 0, message building may block until enough memory has been freed from the queues to allocate the message.
func (*MessageQueue) Shutdown ¶
func (mq *MessageQueue) Shutdown()
Shutdown stops the processing of messages for a message queue.
func (*MessageQueue) Startup ¶
func (mq *MessageQueue) Startup()
Startup starts the processing of messages, and creates an initial message based on the given initial wantlist.
Click to show internal directories.
Click to hide internal directories.