p2p

Jan 31, 2023

Changes in this version

type Config

+ func (conf *Config) Disabled() bool

type Prepared

+ func (p *Prepared) Disabled() bool

type SetupP2P

+ Disabled func() bool

Jan 13, 2023

Changes in this version

+ const DefaultMeshD

+ const DefaultMeshDhi

+ const DefaultMeshDlazy

+ const DefaultMeshDlo

+ func MplexC() (lconf.MsMuxC, error)

+ func NoiseC() (lconf.MsSecC, error)

+ func TlsC() (lconf.MsSecC, error)

+ func YamuxC() (lconf.MsMuxC, error)

type Config

+ FloodPublish bool

+ MeshD int

+ MeshDHi int

+ MeshDLazy int

+ MeshDLo int

+ func (p *Config) ConfigureGossip(params *pubsub.GossipSubParams) []pubsub.Option

+ type GossipSetupConfigurables interface

+ ConfigureGossip func(params *pubsub.GossipSubParams) []pubsub.Option

type Prepared

+ func (p *Prepared) ConfigureGossip(params *pubsub.GossipSubParams) []pubsub.Option

Jan 11, 2023

Changes in this version

+ var DefaultBootnodes = []*enode.Node

Dec 23, 2022

Changes in this version

+ type GossipRuntimeConfig interface

+ P2PSequencerAddress func() common.Address

Dec 14, 2022

Changes in this version

+ type OpStackENRData struct

+ func (o *OpStackENRData) DecodeRLP(s *rlp.Stream) error

+ func (o *OpStackENRData) ENRKey() string

+ func (o *OpStackENRData) EncodeRLP(w io.Writer) error

Jul 12, 2022

Changes in this version

+ const MaxGossipSize

type Config

+ BandwidthMetrics metrics.Reporter

Dec 6, 2022

Changes in this version

+ var DisabledDiscovery = errors.New("discovery disabled")

+ var MessageDomainInvalidSnappy = [4]byte

+ var MessageDomainValidSnappy = [4]byte

+ var NamespaceRPC = "opp2p"

+ var NoConnectionGater = errors.New("no connection gater")

+ var NoConnectionManager = errors.New("no connection manager")

+ var SigningDomainBlocksV1 = [32]byte

+ func BlockSigningHash(cfg *rollup.Config, payloadBytes []byte) (common.Hash, error)

+ func BuildBlocksValidator(log log.Logger, cfg *rollup.Config) pubsub.ValidatorEx

+ func BuildGlobalGossipParams(cfg *rollup.Config) pubsub.GossipSubParams

+ func BuildMsgIdFn(cfg *rollup.Config) pubsub.MsgIdFunction

+ func BuildSubscriptionFilter(cfg *rollup.Config) pubsub.SubscriptionFilter

+ func DefaultConnGater(conf *Config) (connmgr.ConnectionGater, error)

+ func DefaultConnManager(conf *Config) (connmgr.ConnManager, error)

+ func FilterEnodes(log log.Logger, cfg *rollup.Config) func(node *enode.Node) bool

+ func FindActiveTCPPort(h host.Host) (uint16, error)

+ func LogTopicEvents(ctx context.Context, log log.Logger, evHandler *pubsub.TopicEventHandler)

+ func NewGossipSub(p2pCtx context.Context, h host.Host, cfg *rollup.Config, m GossipMetricer) (*pubsub.PubSub, error)

+ func NewNetworkNotifier(log log.Logger, m metrics.Metricer) network.Notifiee

+ func SigningHash(domain [32]byte, chainID *big.Int, payloadBytes []byte) (common.Hash, error)

+ type API interface

+ BlockAddr func(ctx context.Context, ip net.IP) error

+ BlockPeer func(ctx context.Context, p peer.ID) error

+ BlockSubnet func(ctx context.Context, ipnet *net.IPNet) error

+ ConnectPeer func(ctx context.Context, addr string) error

+ DisconnectPeer func(ctx context.Context, id peer.ID) error

+ DiscoveryTable func(ctx context.Context) ([]*enode.Node, error)

+ ListBlockedAddrs func(ctx context.Context) ([]net.IP, error)

+ ListBlockedPeers func(ctx context.Context) ([]peer.ID, error)

+ ListBlockedSubnets func(ctx context.Context) ([]*net.IPNet, error)

+ PeerStats func(ctx context.Context) (*PeerStats, error)

+ Peers func(ctx context.Context, connected bool) (*PeerDump, error)

+ ProtectPeer func(ctx context.Context, p peer.ID) error

+ Self func(ctx context.Context) (*PeerInfo, error)

+ UnblockAddr func(ctx context.Context, ip net.IP) error

+ UnblockPeer func(ctx context.Context, p peer.ID) error

+ UnblockSubnet func(ctx context.Context, ipnet *net.IPNet) error

+ UnprotectPeer func(ctx context.Context, p peer.ID) error

+ type APIBackend struct

+ func NewP2PAPIBackend(node Node, log log.Logger, m metrics.Metricer) *APIBackend

+ func (s *APIBackend) BlockAddr(_ context.Context, ip net.IP) error

+ func (s *APIBackend) BlockPeer(_ context.Context, p peer.ID) error

+ func (s *APIBackend) BlockSubnet(_ context.Context, ipnet *net.IPNet) error

+ func (s *APIBackend) ConnectPeer(ctx context.Context, addr string) error

+ func (s *APIBackend) DisconnectPeer(_ context.Context, id peer.ID) error

+ func (s *APIBackend) DiscoveryTable(_ context.Context) ([]*enode.Node, error)

+ func (s *APIBackend) ListBlockedAddrs(_ context.Context) ([]net.IP, error)

+ func (s *APIBackend) ListBlockedPeers(_ context.Context) ([]peer.ID, error)

+ func (s *APIBackend) ListBlockedSubnets(_ context.Context) ([]*net.IPNet, error)

+ func (s *APIBackend) PeerStats(_ context.Context) (*PeerStats, error)

+ func (s *APIBackend) Peers(ctx context.Context, connected bool) (*PeerDump, error)

+ func (s *APIBackend) ProtectPeer(_ context.Context, p peer.ID) error

+ func (s *APIBackend) Self(ctx context.Context) (*PeerInfo, error)

+ func (s *APIBackend) UnblockAddr(_ context.Context, ip net.IP) error

+ func (s *APIBackend) UnblockPeer(_ context.Context, p peer.ID) error

+ func (s *APIBackend) UnblockSubnet(_ context.Context, ipnet *net.IPNet) error

+ func (s *APIBackend) UnprotectPeer(_ context.Context, p peer.ID) error

+ type Client struct

+ func NewClient(c *rpc.Client) *Client

+ func (c *Client) BlockAddr(ctx context.Context, ip net.IP) error

+ func (c *Client) BlockPeer(ctx context.Context, p peer.ID) error

+ func (c *Client) BlockSubnet(ctx context.Context, ipnet *net.IPNet) error

+ func (c *Client) ConnectPeer(ctx context.Context, addr string) error

+ func (c *Client) DisconnectPeer(ctx context.Context, id peer.ID) error

+ func (c *Client) DiscoveryTable(ctx context.Context) ([]*enode.Node, error)

+ func (c *Client) ListBlockedAddrs(ctx context.Context) ([]net.IP, error)

+ func (c *Client) ListBlockedPeers(ctx context.Context) ([]peer.ID, error)

+ func (c *Client) ListBlockedSubnets(ctx context.Context) ([]*net.IPNet, error)

+ func (c *Client) PeerStats(ctx context.Context) (*PeerStats, error)

+ func (c *Client) Peers(ctx context.Context, connected bool) (*PeerDump, error)

+ func (c *Client) ProtectPeer(ctx context.Context, p peer.ID) error

+ func (c *Client) Self(ctx context.Context) (*PeerInfo, error)

+ func (c *Client) UnblockAddr(ctx context.Context, ip net.IP) error

+ func (c *Client) UnblockPeer(ctx context.Context, p peer.ID) error

+ func (c *Client) UnblockSubnet(ctx context.Context, ipnet *net.IPNet) error

+ func (c *Client) UnprotectPeer(ctx context.Context, p peer.ID) error

+ type Config struct

+ AdvertiseIP net.IP

+ AdvertiseTCPPort uint16

+ AdvertiseUDPPort uint16

+ Bootnodes []*enode.Node

+ ConnGater func(conf *Config) (connmgr.ConnectionGater, error)

+ ConnMngr func(conf *Config) (connmgr.ConnManager, error)

+ DisableP2P bool

+ DiscoveryDB *enode.DB

+ HostMux []lconf.MsMuxC

+ HostSecurity []lconf.MsSecC

+ ListenIP net.IP

+ ListenTCPPort uint16

+ ListenUDPPort uint16

+ NAT bool

+ NoDiscovery bool

+ NoTransportSecurity bool

+ PeersGrace time.Duration

+ PeersHi uint

+ PeersLo uint

+ Priv *crypto.Secp256k1PrivateKey

+ StaticPeers []core.Multiaddr

+ Store ds.Batching

+ TimeoutAccept time.Duration

+ TimeoutDial time.Duration

+ TimeoutNegotiation time.Duration

+ UserAgent string

+ func NewConfig(ctx *cli.Context) (*Config, error)

+ func (conf *Config) Check() error

+ func (conf *Config) Discovery(log log.Logger, rollupCfg *rollup.Config, tcpPort uint16) (*enode.LocalNode, *discover.UDPv5, error)

+ func (conf *Config) Host(log log.Logger, reporter metrics.Reporter) (host.Host, error)

+ func (conf *Config) TargetPeers() uint

+ type ConnectionGater interface

+ BlockAddr func(ip net.IP) error

+ BlockPeer func(p peer.ID) error

+ BlockSubnet func(ipnet *net.IPNet) error

+ ListBlockedAddrs func() []net.IP

+ ListBlockedPeers func() []peer.ID

+ ListBlockedSubnets func() []*net.IPNet

+ UnblockAddr func(ip net.IP) error

+ UnblockPeer func(p peer.ID) error

+ UnblockSubnet func(ipnet *net.IPNet) error

+ type ExtraHostFeatures interface

+ ConnectionGater func() ConnectionGater

+ ConnectionManager func() connmgr.ConnManager

+ type GossipIn interface

+ OnUnsafeL2Payload func(ctx context.Context, from peer.ID, msg *eth.ExecutionPayload) error

+ type GossipMetricer interface

+ RecordGossipEvent func(evType int32)

+ type GossipOut interface

+ Close func() error

+ PublishL2Payload func(ctx context.Context, msg *eth.ExecutionPayload, signer Signer) error

+ func JoinGossip(p2pCtx context.Context, self peer.ID, ps *pubsub.PubSub, log log.Logger, ...) (GossipOut, error)

+ type GossipTopicInfo interface

+ BlocksTopicPeers func() []peer.ID

+ type LocalSigner struct

+ func NewLocalSigner(priv *ecdsa.PrivateKey) *LocalSigner

+ func (s *LocalSigner) Close() error

+ func (s *LocalSigner) Sign(ctx context.Context, domain [32]byte, chainID *big.Int, encodedMsg []byte) (sig *[65]byte, err error)

+ type MessageHandler func(ctx context.Context, from peer.ID, msg interface{}) error

+ func BlocksHandler(...) MessageHandler

+ type Node interface

+ ConnectionGater func() ConnectionGater

+ ConnectionManager func() connmgr.ConnManager

+ Dv5Local func() *enode.LocalNode

+ Dv5Udp func() *discover.UDPv5

+ GossipOut func() GossipOut

+ GossipSub func() *pubsub.PubSub

+ Host func() host.Host

+ type NodeP2P struct

+ func NewNodeP2P(resourcesCtx context.Context, rollupCfg *rollup.Config, log log.Logger, ...) (*NodeP2P, error)

+ func (n *NodeP2P) Close() error

+ func (n *NodeP2P) ConnectionGater() ConnectionGater

+ func (n *NodeP2P) ConnectionManager() connmgr.ConnManager

+ func (n *NodeP2P) DiscoveryProcess(ctx context.Context, log log.Logger, cfg *rollup.Config, connectGoal uint)

+ func (n *NodeP2P) Dv5Local() *enode.LocalNode

+ func (n *NodeP2P) Dv5Udp() *discover.UDPv5

+ func (n *NodeP2P) GossipOut() GossipOut

+ func (n *NodeP2P) GossipSub() *pubsub.PubSub

+ func (n *NodeP2P) Host() host.Host

+ type NotificationsMetricer interface

+ DecPeerCount func()

+ DecStreamCount func()

+ IncPeerCount func()

+ IncStreamCount func()

+ type OptimismENRData struct

+ func (o *OptimismENRData) DecodeRLP(s *rlp.Stream) error

+ func (o *OptimismENRData) ENRKey() string

+ func (o *OptimismENRData) EncodeRLP(w io.Writer) error

+ type PeerDump struct

+ BannedIPS []net.IP

+ BannedPeers []peer.ID

+ BannedSubnets []*net.IPNet

+ Peers map[string]*PeerInfo

+ TotalConnected uint

+ type PeerInfo struct

+ Addresses []string

+ ChainID uint64

+ Connectedness network.Connectedness

+ Direction network.Direction

+ ENR string

+ GossipBlocks bool

+ Latency time.Duration

+ NodeID enode.ID

+ PeerID peer.ID

+ Protected bool

+ ProtocolVersion string

+ Protocols []string

+ UserAgent string

+ type PeerStats struct

+ Banned uint

+ BlocksTopic uint

+ Connected uint

+ Known uint

+ Table uint

+ type Prepared struct

+ HostP2P host.Host

+ LocalNode *enode.LocalNode

+ UDPv5 *discover.UDPv5

+ func (p *Prepared) Check() error

+ func (p *Prepared) Discovery(log log.Logger, rollupCfg *rollup.Config, tcpPort uint16) (*enode.LocalNode, *discover.UDPv5, error)

+ func (p *Prepared) Host(log log.Logger, reporter metrics.Reporter) (host.Host, error)

+ func (p *Prepared) TargetPeers() uint

+ type PreparedSigner struct

+ func (p *PreparedSigner) SetupSigner(ctx context.Context) (Signer, error)

+ type Secp256k1 crypto.Secp256k1PublicKey

+ func (v *Secp256k1) DecodeRLP(s *rlp.Stream) error

+ func (v Secp256k1) ENRKey() string

+ func (v Secp256k1) EncodeRLP(w io.Writer) error

+ type SetupP2P interface

+ Check func() error

+ Discovery func(log log.Logger, rollupCfg *rollup.Config, tcpPort uint16) (*enode.LocalNode, *discover.UDPv5, error)

+ Host func(log log.Logger, reporter metrics.Reporter) (host.Host, error)

+ TargetPeers func() uint

+ type Signer interface

+ Sign func(ctx context.Context, domain [32]byte, chainID *big.Int, encodedMsg []byte) (sig *[65]byte, err error)

+ type SignerSetup interface

+ SetupSigner func(ctx context.Context) (Signer, error)

+ func LoadSignerSetup(ctx *cli.Context) (SignerSetup, error)

+ type TopicSubscriber func(ctx context.Context, sub *pubsub.Subscription)

+ func MakeSubscriber(log log.Logger, msgHandler MessageHandler) TopicSubscriber