network

Documentation

Index

• Constants
• type ConnectionStatus
• type DB
  • func NewDB(store kvstore.KVStore) *DB
  • func (db *DB) Close()
  • func (db *DB) Peer(id peer.ID) (*Peer, error)
  • func (db *DB) SeedPeers() []*Peer
  • func (db *DB) UpdatePeer(p *Peer) error
• type Endpoint
• type Peer
  • func NewPeerFromAddrInfo(addrInfo *peer.AddrInfo) *Peer
  • func NewPeerFromMultiAddr(peerAddrs multiaddr.Multiaddr) (*Peer, error)
  • func (p *Peer) Bytes() ([]byte, error)
  • func (p *Peer) GetConnStatus() ConnectionStatus
  • func (p *Peer) SetConnStatus(cs ConnectionStatus)
  • func (p *Peer) String() string
  • func (p *Peer) ToAddrInfo() *peer.AddrInfo
• type PeerDescriptor

Constants

const DefaultReconnectInterval = 5 * time.Second

Types

type ConnectionStatus

type ConnectionStatus string

ConnectionStatus is an enum for the peer connection status in the gossip layer.

const (
	// ConnStatusDisconnected means that there is no real connection established in the gossip layer for that peer.
	ConnStatusDisconnected ConnectionStatus = "disconnected"
	// ConnStatusConnected means that there is a real connection established in the gossip layer for that peer.
	ConnStatusConnected ConnectionStatus = "connected"
)

type DB

type DB struct {
	// contains filtered or unexported fields
}

DB is the peer database, storing previously seen peers and any collected properties of them.

func NewDB

func NewDB(store kvstore.KVStore) *DB

NewDB creates a new peer database.

func (*DB) Close

func (db *DB) Close()

Close closes the peer database.

func (*DB) Peer

func (db *DB) Peer(id peer.ID) (*Peer, error)

Peer retrieves a peer from the database.

func (*DB) SeedPeers

func (db *DB) SeedPeers() []*Peer

SeedPeers retrieves random nodes to be used as potential bootstrap peers.

func (*DB) UpdatePeer

func (db *DB) UpdatePeer(p *Peer) error

UpdatePeer updates a peer in the database.

type Endpoint

type Endpoint interface {
	LocalPeerID() peer.ID
	RegisterProtocol(factory func() proto.Message, handler func(peer.ID, proto.Message) error)
	UnregisterProtocol()
	Send(packet proto.Message, to ...peer.ID)
	Shutdown()
}

type Peer

type Peer struct {
	ID            peer.ID
	PublicKey     ed25519.PublicKey
	PeerAddresses []multiaddr.Multiaddr
	ConnStatus    *atomic.Value
	RemoveCh      chan struct{}
	DoneCh        chan struct{}
}

func NewPeerFromAddrInfo

func NewPeerFromAddrInfo(addrInfo *peer.AddrInfo) *Peer

func NewPeerFromMultiAddr

func NewPeerFromMultiAddr(peerAddrs multiaddr.Multiaddr) (*Peer, error)

func (*Peer) Bytes

func (p *Peer) Bytes() ([]byte, error)

func (*Peer) GetConnStatus

func (p *Peer) GetConnStatus() ConnectionStatus

func (*Peer) SetConnStatus

func (p *Peer) SetConnStatus(cs ConnectionStatus)

func (*Peer) String

func (p *Peer) String() string

func (*Peer) ToAddrInfo

func (p *Peer) ToAddrInfo() *peer.AddrInfo

type PeerDescriptor

type PeerDescriptor struct {
	Addresses []multiaddr.Multiaddr `json:"addresses"`
}

PeerDescriptor defines a peer record in the manual peering layer.