p2pnet

Oct 3, 2023

Changes in this version

+ const DefaultMaxUnicastMsgSize

+ const DefaultUnicastTimeout

+ const LargeMsgMaxUnicastMsgSize

+ const LargeMsgUnicastTimeout

+ var ErrNetworkShutdown = errors.New("network has already shutdown")

+ var ErrUnicastMsgWithoutSub = errors.New(...)

+ var NotEjectedFilter = filter.Not(filter.Ejected)

+ func DefaultValidators(log zerolog.Logger, flowID flow.Identifier) []network.MessageValidator

+ func UnicastMaxMsgSizeByCode(payload []byte) (int, error)

+ type Network struct

+ func NewNetwork(param *NetworkConfig, opts ...NetworkOption) (*Network, error)

+ func (n *Network) Identities() flow.IdentityList

+ func (n *Network) Identity(pid peer.ID) (*flow.Identity, bool)

+ func (n *Network) MulticastOnChannel(channel channels.Channel, message interface{}, num uint, ...) error

+ func (n *Network) OnAllowListNotification(notification *network.AllowListingUpdate)

+ func (n *Network) OnDisallowListNotification(notification *network.DisallowListingUpdate)

+ func (n *Network) PublishOnChannel(channel channels.Channel, message interface{}, targetIDs ...flow.Identifier) error

+ func (n *Network) Receive(msg network.IncomingMessageScope) error

+ func (n *Network) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

+ func (n *Network) RegisterBlobService(channel channels.Channel, ds datastore.Batching, ...) (network.BlobService, error)

+ func (n *Network) RegisterPingService(pingProtocol protocol.ID, provider network.PingInfoProvider) (network.PingService, error)

+ func (n *Network) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

+ func (n *Network) Subscribe(channel channels.Channel) error

+ func (n *Network) Topology() flow.IdentityList

+ func (n *Network) UnRegisterChannel(channel channels.Channel) error

+ func (n *Network) UnicastOnChannel(channel channels.Channel, payload interface{}, targetID flow.Identifier) error

+ func (n *Network) Unsubscribe(channel channels.Channel) error

+ func (n *Network) UpdateNodeAddresses()

+ type NetworkConfig struct

+ AlspCfg *alspmgr.MisbehaviorReportManagerConfig

+ BitSwapMetrics module.BitswapMetrics

+ Codec network.Codec

+ ConduitFactory network.ConduitFactory

+ IdentityProvider module.IdentityProvider

+ IdentityTranslator p2p.IDTranslator

+ Libp2pNode p2p.LibP2PNode

+ Logger zerolog.Logger

+ Me module.Local

+ Metrics module.NetworkCoreMetrics

+ ReceiveCache *netcache.ReceiveCache

+ SlashingViolationConsumerFactory func(network.ConduitAdapter) network.ViolationsConsumer

+ SporkId flow.Identifier

+ Topology network.Topology

+ UnicastMessageTimeout time.Duration

+ func (cfg *NetworkConfig) Validate()

+ type NetworkConfigOption func(*NetworkConfig)

+ func WithAlspConfig(cfg *alspmgr.MisbehaviorReportManagerConfig) NetworkConfigOption

+ func WithCodec(codec network.Codec) NetworkConfigOption

+ func WithSlashingViolationConsumerFactory(factory func(adapter network.ConduitAdapter) network.ViolationsConsumer) NetworkConfigOption

+ type NetworkOption func(*Network)

+ func WithAlspManager(mgr network.MisbehaviorReportManager) NetworkOption

+ func WithMessageValidators(validators ...network.MessageValidator) NetworkOption

+ func WithPeerManagerFilters(filters ...p2p.PeerFilter) NetworkOption

+ func WithPreferredUnicastProtocols(protocols ...protocols.ProtocolName) NetworkOption

+ func WithUnicastRateLimiters(limiters *ratelimit.RateLimiters) NetworkOption