p2p

package

Go to main page

Versions in this module

v0

v0.9.8

Sep 6, 2022

v0.9.7

Sep 5, 2022

Changes in this version

type AcceptMatcher

+ Ctx context.Context

+ CtxCancel context.CancelFunc

v0.9.6

Sep 1, 2022

Changes in this version

type AcceptMatcher

+ StreamChMutex sync.RWMutex

v0.9.5

Aug 31, 2022

Changes in this version

type Manager

+ func (m *Manager) AllNeighborsIDs() (ids []identity.ID)

+ func (m *Manager) Send(packet proto.Message, protocolID protocol.ID, to ...identity.ID) []*Neighbor

v0.9.4

Aug 8, 2022

Changes in this version

+ var ErrDuplicateAccept = errors.New("accept request for that peer already exists")

+ var ErrDuplicateNeighbor = errors.New("already connected")

+ var ErrLoopbackNeighbor = errors.New("loopback connection not allowed")

+ var ErrNeighborQueueFull = errors.New("send queue is full")

+ var ErrNoP2P = errors.New("peer does not have a p2p service")

+ var ErrNotRunning = errors.New("manager not running")

+ var ErrTimeout = errors.New("accept timeout")

+ var ErrUnknownNeighbor = errors.New("unknown neighbor")

+ func GetAddress(p *peer.Peer) string

+ type AcceptMatcher struct

+ Libp2pID libp2ppeer.ID

+ Peer *peer.Peer

+ StreamCh chan *PacketsStream

+ type ConnectPeerOption func(conf *connectPeerConfig)

+ func WithNoDefaultTimeout() ConnectPeerOption

+ type Manager struct

+ func NewManager(libp2pHost host.Host, local *peer.Local, log *logger.Logger) *Manager

+ func (m *Manager) AddInbound(ctx context.Context, p *peer.Peer, group NeighborsGroup, ...) error

+ func (m *Manager) AddOutbound(ctx context.Context, p *peer.Peer, group NeighborsGroup, ...) error

+ func (m *Manager) AllNeighbors() []*Neighbor

+ func (m *Manager) CloseStream(s network.Stream)

+ func (m *Manager) DropNeighbor(id identity.ID, group NeighborsGroup) error

+ func (m *Manager) GetNeighbor(id identity.ID) (*Neighbor, error)

+ func (m *Manager) GetNeighborsByID(ids []identity.ID) []*Neighbor

+ func (m *Manager) GetP2PHost() host.Host

+ func (m *Manager) MatchNewStream(stream network.Stream) *AcceptMatcher

+ func (m *Manager) NeighborGroupEvents(group NeighborsGroup) *NeighborGroupEvents

+ func (m *Manager) RegisterProtocol(protocolID protocol.ID, protocolHandler *ProtocolHandler)

+ func (m *Manager) Stop()

+ func (m *Manager) UnregisterProtocol(protocolID protocol.ID)

+ type Neighbor struct

+ Events *NeighborEvents

+ Group NeighborsGroup

+ Log *logger.Logger

+ func NewNeighbor(p *peer.Peer, group NeighborsGroup, protocols map[protocol.ID]*PacketsStream, ...) *Neighbor

+ func (n *Neighbor) Close()

+ func (n *Neighbor) ConnectionEstablished() time.Time

+ func (n *Neighbor) GetStream(protocol protocol.ID) *PacketsStream

+ func (n *Neighbor) PacketsRead() (count uint64)

+ func (n *Neighbor) PacketsWritten() (count uint64)

+ type NeighborAddedEvent struct

+ Neighbor *Neighbor

+ type NeighborDisconnectedEvent struct

+ type NeighborEvents struct

+ Disconnected *event.Event[*NeighborDisconnectedEvent]

+ PacketReceived *event.Event[*NeighborPacketReceivedEvent]

+ func NewNeighborEvents() (new *NeighborEvents)

+ type NeighborGroupEvents struct

+ NeighborAdded *event.Event[*NeighborAddedEvent]

+ NeighborRemoved *event.Event[*NeighborRemovedEvent]

+ func NewNeighborGroupEvents() (new *NeighborGroupEvents)

+ type NeighborPacketReceivedEvent struct

+ Neighbor *Neighbor

+ Packet proto.Message

+ Protocol protocol.ID

+ type NeighborRemovedEvent struct

+ Neighbor *Neighbor

+ type NeighborsGroup int8

+ const NeighborsGroupAuto

+ const NeighborsGroupManual

+ type PacketsStream struct

+ func NewPacketsStream(stream network.Stream, packetFactory func() proto.Message) *PacketsStream

+ func (ps *PacketsStream) ReadPacket(message proto.Message) error

+ func (ps *PacketsStream) WritePacket(message proto.Message) error

+ type ProtocolHandler struct

+ NegotiationReceive func(ps *PacketsStream) error

+ NegotiationSend func(ps *PacketsStream) error

+ PacketFactory func() proto.Message

+ PacketHandler func(*Neighbor, proto.Message) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL