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

v0

v0.18.8

May 26, 2024

v0.18.7

May 21, 2024

v0.18.6

May 7, 2024

v0.18.5

May 3, 2024

v0.18.4

Apr 6, 2024

v0.18.3

Mar 15, 2024

v0.18.2

Mar 13, 2024

v0.18.1

Feb 18, 2024

v0.18.0

Feb 13, 2024

Changes in this version

+ const HandshakeTimeout

+ const IdleTimeout

+ const MaxIncomingStreams

+ const MsgPriorityHigh

+ const MsgPriorityNormal

+ const PeerMessageTypeAuthentication

+ const PeerMessageTypeCommitments

+ const PeerMessageTypeConsumers

+ const PeerMessageTypeFullChallenge

+ const PeerMessageTypeGraph

+ const PeerMessageTypePing

+ const PeerMessageTypeRelay

+ const PeerMessageTypeSnapshotAnnouncement

+ const PeerMessageTypeSnapshotCommitment

+ const PeerMessageTypeSnapshotConfirm

+ const PeerMessageTypeSnapshotFinalization

+ const PeerMessageTypeSnapshotResponse

+ const PeerMessageTypeTransaction

+ const PeerMessageTypeTransactionChallenge

+ const PeerMessageTypeTransactionRequest

+ const ReadDeadline

+ const TransportMessageHeaderSize

+ const TransportMessageMaxSize

+ const TransportMessageVersion

+ const WriteDeadline

+ type AuthToken struct

+ Data []byte

+ IsRelayer bool

+ PeerId crypto.Hash

+ Timestamp uint64

+ type ChanMsg struct

+ type Client interface

+ Close func() error

+ Receive func() (*TransportMessage, error)

+ RemoteAddr func() net.Addr

+ Send func([]byte) error

+ type MetricPool struct

+ PeerMessageTypeAuthentication uint32

+ PeerMessageTypeCommitments uint32

+ PeerMessageTypeFullChallenge uint32

+ PeerMessageTypeGraph uint32

+ PeerMessageTypePing uint32

+ PeerMessageTypeRelay uint32

+ PeerMessageTypeSnapshotAnnouncement uint32

+ PeerMessageTypeSnapshotCommitment uint32

+ PeerMessageTypeSnapshotConfirm uint32

+ PeerMessageTypeSnapshotFinalization uint32

+ PeerMessageTypeSnapshotResponse uint32

+ PeerMessageTypeTransaction uint32

+ PeerMessageTypeTransactionChallenge uint32

+ PeerMessageTypeTransactionRequest uint32

+ func (mp *MetricPool) String() string

+ type Peer struct

+ Address string

+ IdForNetwork crypto.Hash

+ func NewPeer(handle SyncHandle, idForNetwork crypto.Hash, addr string, isRelayer bool) *Peer

+ func (me *Peer) ConfirmSnapshotForPeer(idForNetwork, snap crypto.Hash)

+ func (me *Peer) ConnectRelayer(idForNetwork crypto.Hash, addr string)

+ func (me *Peer) ListenConsumers() error

+ func (me *Peer) Metric() map[string]*MetricPool

+ func (me *Peer) Neighbors() []*Peer

+ func (me *Peer) SendCommitmentsMessage(idForNetwork crypto.Hash, commitments []*crypto.Key) error

+ func (me *Peer) SendFullChallengeMessage(idForNetwork crypto.Hash, s *common.Snapshot, ...) error

+ func (me *Peer) SendGraphMessage(idForNetwork crypto.Hash) error

+ func (me *Peer) SendSnapshotAnnouncementMessage(idForNetwork crypto.Hash, s *common.Snapshot, R crypto.Key, spend crypto.Key) error

+ func (me *Peer) SendSnapshotCommitmentMessage(idForNetwork crypto.Hash, snap crypto.Hash, R crypto.Key, wantTx bool) error

+ func (me *Peer) SendSnapshotConfirmMessage(idForNetwork crypto.Hash, snap crypto.Hash) error

+ func (me *Peer) SendSnapshotFinalizationMessage(idForNetwork crypto.Hash, s *common.Snapshot) error

+ func (me *Peer) SendSnapshotResponseMessage(idForNetwork crypto.Hash, snap crypto.Hash, si *[32]byte) error

+ func (me *Peer) SendTransactionChallengeMessage(idForNetwork crypto.Hash, snap crypto.Hash, cosi *crypto.CosiSignature, ...) error

+ func (me *Peer) SendTransactionMessage(idForNetwork crypto.Hash, ver *common.VersionedTransaction) error

+ func (me *Peer) SendTransactionRequestMessage(idForNetwork crypto.Hash, tx crypto.Hash) error

+ func (me *Peer) Teardown()

+ type PeerMessage struct

+ Challenge crypto.Key

+ Commitment crypto.Key

+ Commitments []*crypto.Key

+ Cosi crypto.CosiSignature

+ Data []byte

+ Graph []*SyncPoint

+ Response [32]byte

+ Snapshot *common.Snapshot

+ SnapshotHash crypto.Hash

+ Transaction *common.VersionedTransaction

+ TransactionHash crypto.Hash

+ Type uint8

+ WantTx bool

+ type QuicClient struct

+ func NewQuicConsumer(ctx context.Context, relayer string) (*QuicClient, error)

+ func (c *QuicClient) Close() error

+ func (c *QuicClient) Receive() (*TransportMessage, error)

+ func (c *QuicClient) RemoteAddr() net.Addr

+ func (c *QuicClient) Send(data []byte) error

+ type QuicRelayer struct

+ func NewQuicRelayer(listenAddr string) (*QuicRelayer, error)

+ func (t *QuicRelayer) Accept(ctx context.Context) (Client, error)

+ func (t *QuicRelayer) Close() error

+ type SyncHandle interface

+ AuthenticateAs func(recipientId crypto.Hash, msg []byte, timeoutSec int64) (*AuthToken, error)

+ BuildAuthenticationMessage func(relayerId crypto.Hash) []byte

+ BuildGraph func() []*SyncPoint

+ CachePutTransaction func(peerId crypto.Hash, ver *common.VersionedTransaction) error

+ CosiAggregateSelfCommitments func(peerId crypto.Hash, snap crypto.Hash, commitment *crypto.Key, wantTx bool, ...) error

+ CosiAggregateSelfResponses func(peerId crypto.Hash, snap crypto.Hash, response *[32]byte) error

+ CosiQueueExternalAnnouncement func(peerId crypto.Hash, s *common.Snapshot, R *crypto.Key, sig *crypto.Signature) error

+ CosiQueueExternalChallenge func(peerId crypto.Hash, snap crypto.Hash, cosi *crypto.CosiSignature, ...) error

+ CosiQueueExternalCommitments func(peerId crypto.Hash, commitments []*crypto.Key, data []byte, ...) error

+ CosiQueueExternalFullChallenge func(peerId crypto.Hash, s *common.Snapshot, commitment, challenge *crypto.Key, ...) error

+ GetCacheStore func() *ristretto.Cache

+ ReadAllNodesWithoutState func() []crypto.Hash

+ ReadSnapshotsForNodeRound func(nodeIdWithNetwork crypto.Hash, round uint64) ([]*common.SnapshotWithTopologicalOrder, error)

+ ReadSnapshotsSinceTopology func(offset, count uint64) ([]*common.SnapshotWithTopologicalOrder, error)

+ SendTransactionToPeer func(peerId, tx crypto.Hash) error

+ SignData func(data []byte) crypto.Signature

+ UpdateSyncPoint func(peerId crypto.Hash, points []*SyncPoint, data []byte, sig *crypto.Signature) error

+ VerifyAndQueueAppendSnapshotFinalization func(peerId crypto.Hash, s *common.Snapshot) error

+ type SyncPoint struct

+ Hash crypto.Hash

+ NodeId crypto.Hash

+ Number uint64

+ Pool any

+ type Transport interface

+ Accept func(ctx context.Context) (Client, error)

+ Close func() error

+ Dial func(ctx context.Context) (Client, error)

+ Listen func() error

+ type TransportMessage struct

+ Data []byte

+ Size uint32

+ Version uint8