v2

Jun 26, 2023

Changes in this version

+ type ConnectionGater struct

+ func NewConnectionGater(logger *zap.Logger) *ConnectionGater

+ func (c *ConnectionGater) InterceptAccept(n network.ConnMultiaddrs) (allow bool)

+ func (c *ConnectionGater) InterceptAddrDial(pid peer.ID, m multiaddr.Multiaddr) (allow bool)

+ func (c *ConnectionGater) InterceptPeerDial(_ peer.ID) (allow bool)

+ func (c *ConnectionGater) InterceptSecured(_ network.Direction, _ peer.ID, _ network.ConnMultiaddrs) (allow bool)

+ func (c *ConnectionGater) InterceptUpgraded(_ network.Conn) (allow bool, reason control.DisconnectReason)

+ func (c *ConnectionGater) NotifyDisconnect(addr multiaddr.Multiaddr)

+ type PeerData struct

+ AddrInfo peer.AddrInfo

+ ENR *enode.Node

+ Origin peers.Origin

May 12, 2023

Changes in this version

type PeerConnectionStrategy

+ func (c *PeerConnectionStrategy) SetHost(h host.Host)

Jan 23, 2023

Changes in this version

+ type PeerConnectionStrategy struct

+ func NewPeerConnectionStrategy(h host.Host, cacheSize int, minPeers int, dialTimeout time.Duration, ...) (*PeerConnectionStrategy, error)

+ func (c *PeerConnectionStrategy) PeerChannel() chan<- peer.AddrInfo

+ func (c *PeerConnectionStrategy) Start(ctx context.Context) error

+ func (c *PeerConnectionStrategy) Stop()

Dec 21, 2022

Changes in this version

+ type Broadcaster interface

+ Close func()

+ Register func(topic *string, newch chan<- *protocol.Envelope)

+ Submit func(*protocol.Envelope)

+ Unregister func(topic *string, newch chan<- *protocol.Envelope)

+ WaitRegister func(topic *string, newch chan<- *protocol.Envelope) doneCh

+ WaitUnregister func(topic *string, newch chan<- *protocol.Envelope) doneCh

+ func NewBroadcaster(buflen int) Broadcaster