Versions in this module Expand all Collapse all v0 v0.2.0 May 14, 2022 Changes in this version type Messenger + func (m *Messenger) Peers() []peer.ID v0.1.0 Oct 1, 2021 Changes in this version + type Messenger struct + func New(host host.Host, opts ...Option) (*Messenger, error) + func (m *Messenger) Broadcast(ctx context.Context, out serde.Message) <-chan error + func (m *Messenger) Close() error + func (m *Messenger) ClosedStream(_ network.Network, _ network.Stream) + func (m *Messenger) Connected(_ network.Network, c network.Conn) + func (m *Messenger) Disconnected(_ network.Network, _ network.Conn) + func (m *Messenger) Events() <-chan PeerEvent + func (m *Messenger) Host() host.Host + func (m *Messenger) Listen(_ network.Network, _ ma.Multiaddr) + func (m *Messenger) ListenClose(_ network.Network, _ ma.Multiaddr) + func (m *Messenger) OpenedStream(_ network.Network, _ network.Stream) + func (m *Messenger) Receive(ctx context.Context) (serde.Message, peer.ID, error) + func (m *Messenger) Send(ctx context.Context, out serde.Message, to peer.ID) <-chan error + type Option func(messenger *Messenger) + func WithMessageType(msg serde.Message) Option + func WithProtocols(pids ...protocol.ID) Option + type PeerEvent struct + ID peer.ID + State inet.Connectedness