Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

p2p

package

Go to main page

Versions in this module

v1

v1.1.0

Dec 12, 2023

v1.0.5

Nov 29, 2023

Changes in this version

+ type Marshaler interface

+ func WrapSSZObject(sszObj common.SSZObj) Marshaler

+ func WrapSpecObject(spec *common.Spec, specObj common.SpecObj) Marshaler

+ type Status struct

+ func NewStatus() *Status

+ func (s *Status) GetForkDigest() common.ForkDigest

+ func (s *Status) SetFinalizedCheckpoint(c common.Checkpoint)

+ func (s *Status) SetForkDigest(d common.ForkDigest)

+ func (s *Status) SetHead(h tree.Root, slot common.Slot)

type TestPeer

+ func (p *TestPeer) BroadcastBlobSidecar(spec *common.Spec, blobSidecar *deneb.BlobSidecar, subnet *uint64) error

+ func (p *TestPeer) BroadcastBlobSidecars(spec *common.Spec, blobSidecars ...*deneb.BlobSidecar) error

+ func (p *TestPeer) BroadcastSignedBeaconBlock(spec *common.Spec, signedBeaconBlock *deneb.SignedBeaconBlock) error

type TestPeers

+ func (p TestPeers) BroadcastBlobSidecar(spec *common.Spec, blobSidecar *deneb.BlobSidecar, subnet *uint64) error

+ func (p TestPeers) BroadcastBlobSidecars(spec *common.Spec, blobSidecars ...*deneb.BlobSidecar) error

+ func (p TestPeers) BroadcastSignedBeaconBlock(spec *common.Spec, signedBeaconBlockDeneb *deneb.SignedBeaconBlock) error

v1.0.4

Oct 25, 2023

v1.0.3

Oct 21, 2023

v1.0.2

Oct 18, 2023

v1.0.1

Oct 17, 2023

v1.0.0

Oct 17, 2023

Changes in this version

+ const GoodbyeProtocolID

+ const MetaDataProtocolID

+ const PingProtocolID

+ const StatusProtocolID

+ var MESSAGE_DOMAIN_INVALID_SNAPPY = [4]byte

+ var MESSAGE_DOMAIN_VALID_SNAPPY = [4]byte

+ func ConvertFromInterfacePrivKey(privkey crypto.PrivKey) (*ecdsa.PrivateKey, error)

+ func EncodeGossip(topic string, msg fastssz.Marshaler) ([]byte, []byte, error)

+ func PublishTopic(ctx context.Context, topicHandle *pubsub.Topic, data []byte, ...) error

+ type BeaconClientPeer struct

+ BeaconClient ENR

+ func (bcp *BeaconClientPeer) GetPeerAddrInfo(ctx context.Context) (*peer.AddrInfo, error)

+ type ENR interface

+ ENR func(ctx context.Context) (string, error)

+ type Goodbye = primitives.SSZUint64

+ type PingData = primitives.SSZUint64

+ type TestP2P struct

+ BeaconPortStart int64

+ ChainStatus *common.Status

+ ExternalIP net.IP

+ InstanceID uint64

+ MaxDevP2PSessionReuses int

+ func (t *TestP2P) GetNextPeerIDs(count uint64) []string

+ func (t *TestP2P) GetTestPeer(ctx context.Context, count int) (TestPeers, error)

+ func (t *TestP2P) NewTestPeer(ctx context.Context, port int64) (*TestPeer, error)

+ type TestPeer struct

+ Host host.Host

+ ID TestPeerIndex

+ LocalNode *enode.LocalNode

+ MetaData *eth.MetaDataV1

+ PrivateKey crypto.PrivKey

+ PubSub *pubsub.PubSub

+ PublicKey crypto.PubKey

+ func (p *TestPeer) BroadcastSignedBeaconBlockDeneb(signedBeaconBlockDeneb *eth.SignedBeaconBlockDeneb) error

+ func (p *TestPeer) BroadcastSignedBlobSidecar(signedBlobSidecar *eth.SignedBlobSidecar, subnet *uint64) error

+ func (p *TestPeer) Close() error

+ func (p *TestPeer) Connect(ctx context.Context, peer *BeaconClientPeer) error

+ func (p *TestPeer) Goodbye(ctx context.Context, peer peer.ID) error

+ func (p *TestPeer) SendInitialStatus(ctx context.Context, peer peer.ID) error

+ func (p *TestPeer) SetupStreams() error

+ func (p *TestPeer) WaitForP2PConnection(ctx context.Context) error

+ type TestPeerIndex uint64

+ func (id TestPeerIndex) Keys(instanceID uint64) (crypto.PrivKey, crypto.PubKey)

+ func (id TestPeerIndex) PeerID(instanceID uint64) string

+ func (id TestPeerIndex) String() string

+ type TestPeers []*TestPeer

+ func (p TestPeers) BroadcastSignedBeaconBlockDeneb(signedBeaconBlockDeneb *eth.SignedBeaconBlockDeneb) error

+ func (p TestPeers) BroadcastSignedBlobSidecar(signedBlobSidecar *eth.SignedBlobSidecar, subnet *uint64) error

+ func (pl TestPeers) Close() error