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

v3

v3.8.0

Apr 23, 2024

v3.7.0

Apr 14, 2024

v3.6.4

Apr 13, 2024

v3.6.3

Apr 13, 2024

v3.6.2

Apr 13, 2024

v3.6.1

Apr 13, 2024

v3.6.0

Apr 13, 2024

Changes in this version

type Client

+ func (c *Client) PreferredAddressPort() netip.AddrPort

v3.5.0

Apr 12, 2024

v3.4.0

Apr 10, 2024

Changes in this version

type Server

+ func (s *Server) HandshakeConsensusId() types.Hash

v3.3.0

Apr 7, 2024

v3.2.1

Apr 6, 2024

v3.2.0

Apr 6, 2024

v3.1.0

Apr 5, 2024

v3.0.2

Apr 5, 2024

v3.0.1

Apr 3, 2024

v3.0.0

Apr 3, 2024

Changes in this version

+ const DefaultBanTime

+ const HandshakeChallengeDifficulty

+ const HandshakeChallengeSize

+ const MaxBufferSize

+ const MessageBlockBroadcast

+ const MessageBlockBroadcastCompact

+ const MessageBlockNotify

+ const MessageBlockRequest

+ const MessageBlockResponse

+ const MessageHandshakeChallenge

+ const MessageHandshakeSolution

+ const MessageInternal

+ const MessageListenPort

+ const MessagePeerListRequest

+ const MessagePeerListResponse

+ const PeerListResponseMaxPeers

+ const PeerRequestDelay

+ func CalculateChallengeHash(challenge HandshakeChallenge, consensusId types.Hash, solution uint64) (hash types.Hash, ok bool)

+ func FindChallengeSolution(challenge HandshakeChallenge, consensusId types.Hash, stop *atomic.Bool) (solution uint64, hash types.Hash, ok bool)

+ type BanEntry struct

+ Error error

+ Expiration uint64

+ type Client struct

+ AddressPort netip.AddrPort

+ BroadcastMaxHeight atomic.Uint64

+ BroadcastedHashes *utils.CircularBuffer[types.Hash]

+ Closed atomic.Bool

+ Connection *net.TCPConn

+ ConnectionTime time.Time

+ HandshakeComplete atomic.Bool

+ IsIncomingConnection bool

+ LastActiveTimestamp atomic.Uint64

+ LastBlockRequestTimestamp atomic.Uint64

+ LastBroadcastTimestamp atomic.Uint64

+ LastIncomingPeerListRequestTime time.Time

+ LastKnownTip atomic.Pointer[sidechain.PoolBlock]

+ LastPeerListRequestTimestamp atomic.Uint64

+ ListenPort atomic.Uint32

+ NextOutgoingPeerListRequestTimestamp atomic.Uint64

+ Owner *Server

+ PeerId atomic.Uint64

+ PingDuration atomic.Uint64

+ RequestedHashes *utils.CircularBuffer[types.Hash]

+ SentHandshakeSolution atomic.Bool

+ VersionInformation p2pooltypes.PeerVersionInformation

+ func NewClient(owner *Server, conn *net.TCPConn) *Client

+ func (c *Client) Ban(duration time.Duration, err error)

+ func (c *Client) BanError() error

+ func (c *Client) Close() bool

+ func (c *Client) IsGood() bool

+ func (c *Client) OnAfterHandshake()

+ func (c *Client) OnConnection()

+ func (c *Client) Read(buf []byte) (n int, err error)

+ func (c *Client) ReadByte() (b byte, err error)

+ func (c *Client) SendBlockNotify(id types.Hash)

+ func (c *Client) SendBlockRequest(id types.Hash)

+ func (c *Client) SendBlockRequestWithBound(id types.Hash, bound int) bool

+ func (c *Client) SendBlockResponse(block *sidechain.PoolBlock)

+ func (c *Client) SendListenPort()

+ func (c *Client) SendMessage(message *ClientMessage)

+ func (c *Client) SendMissingBlockRequest(hash types.Hash)

+ func (c *Client) SendMissingBlockRequestAtRandom(hash types.Hash, allowedClients []*Client) []*Client

+ func (c *Client) SendPeerListRequest()

+ func (c *Client) SendPeerListResponse(list []netip.AddrPort)

+ func (c *Client) SendUniqueBlockRequest(hash types.Hash)

+ func (c *Client) SetError(err error)

+ type ClientMessage struct

+ Buffer []byte

+ MessageId MessageId

+ type HandshakeChallenge [HandshakeChallengeSize]byte

+ type InternalMessageId uint64

+ type MessageId uint8

+ type P2PoolInterface interface

+ ClientRPC func() *client.Client

+ GetChainMainTip func() *sidechain.ChainMain

+ GetMinerDataTip func() *p2pooltypes.MinerData

+ MainChain func() *mainchain.MainChain

+ SideChain func() *sidechain.SideChain

+ type PeerList []*PeerListEntry

+ func (l PeerList) Delete(addr netip.Addr) PeerList

+ func (l PeerList) Get(addr netip.Addr) *PeerListEntry

+ type PeerListEntry struct

+ AddressPort netip.AddrPort

+ FailedConnections atomic.Uint32

+ LastSeenTimestamp atomic.Uint64

+ type Server struct

+ MaxIncomingPeers uint32

+ MaxOutgoingPeers uint32

+ NumIncomingConnections atomic.Int32

+ NumOutgoingConnections atomic.Int32

+ PendingOutgoingConnections *utils.CircularBuffer[string]

+ func NewServer(p2pool P2PoolInterface, listenAddress string, externalListenPort uint16, ...) (*Server, error)

+ func (s *Server) AddCachedBlock(block *sidechain.PoolBlock)

+ func (s *Server) AddToPeerList(addressPort netip.AddrPort)

+ func (s *Server) Ban(ip netip.Addr, duration time.Duration, err error)

+ func (s *Server) Broadcast(block *sidechain.PoolBlock)

+ func (s *Server) CleanupBanList()

+ func (s *Server) ClearCachedBlocks()

+ func (s *Server) Clients() []*Client

+ func (s *Server) Close()

+ func (s *Server) Connect(addrPort netip.AddrPort) error

+ func (s *Server) Consensus() *sidechain.Consensus

+ func (s *Server) DirectConnect(addrPort netip.AddrPort) (*Client, error)

+ func (s *Server) DownloadMissingBlocks()

+ func (s *Server) ExternalListenPort() uint16

+ func (s *Server) GetAddressConnected(addr netip.Addr) (result []*Client)

+ func (s *Server) GetAddressConnectedPrefix(prefix netip.Prefix) (result []*Client)

+ func (s *Server) GetCachedBlock(hash types.Hash) *sidechain.PoolBlock

+ func (s *Server) GetFastestClient() *Client

+ func (s *Server) GetOutgoingIPv6() []netip.Addr

+ func (s *Server) IsBanned(ip netip.Addr) (bool, *BanEntry)

+ func (s *Server) Listen() (err error)

+ func (s *Server) ListenPort() uint16

+ func (s *Server) MainChain() *mainchain.MainChain

+ func (s *Server) PeerId() uint64

+ func (s *Server) PeerList() PeerList

+ func (s *Server) RefreshOutgoingIPv6()

+ func (s *Server) RemoveFromPeerList(ip netip.Addr)

+ func (s *Server) SideChain() *sidechain.SideChain

+ func (s *Server) UpdateClientConnections()

+ func (s *Server) UpdateInPeerList(addressPort netip.AddrPort)

+ func (s *Server) UpdatePeerList()

+ func (s *Server) VersionInformation() *p2pooltypes.PeerVersionInformation