net

Documentation

Index

• Constants
• func FilecoinDHT(network string) protocol.ID
• func NewGossipSub(ctx context.Context, h host.Host, sk *ScoreKeeper, networkName string, ...) (*pubsub.PubSub, error)
• func ParseAddresses(ctx context.Context, addrs []string) ([]peer.AddrInfo, error)
• type Network
  • func New(host host.Host, rawHost types.RawHost, router *Router, ...) *Network
  • func (network *Network) AgentVersion(ctx context.Context, p peer.ID) (string, error)
  • func (network *Network) AutoNatStatus() (types.NatInfo, error)
  • func (network *Network) Connect(ctx context.Context, p peer.AddrInfo) error
  • func (network *Network) Connectedness(p peer.ID) (network2.Connectedness, error)
  • func (network *Network) Disconnect(p peer.ID) error
  • func (network *Network) GetBandwidthStats() metrics.Stats
  • func (network *Network) GetBandwidthStatsByPeer() (map[string]metrics.Stats, error)
  • func (network *Network) GetBandwidthStatsByProtocol() (map[protocol.ID]metrics.Stats, error)
  • func (network *Network) GetPeerAddresses() []ma.Multiaddr
  • func (network *Network) GetPeerID() peer.ID
  • func (network *Network) PeerInfo(ctx context.Context, p peer.ID) (*types.ExtendedPeerInfo, error)
  • func (network *Network) Peers(ctx context.Context) ([]peer.AddrInfo, error)
  • func (network *Network) ProtectAdd(peers []peer.ID) error
  • func (network *Network) ProtectList() ([]peer.ID, error)
  • func (network *Network) ProtectRemove(peers []peer.ID) error
• type Router
  • func NewRouter(r routing.Routing) *Router
  • func (r *Router) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)
  • func (r *Router) FindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo
  • func (r *Router) GetClosestPeers(ctx context.Context, key string) ([]peer.ID, error)
• type ScoreKeeper
  • func NewScoreKeeper() *ScoreKeeper
  • func (sk *ScoreKeeper) Get() map[peer.ID]*pubsub.PeerScoreSnapshot
  • func (sk *ScoreKeeper) Update(scores map[peer.ID]*pubsub.PeerScoreSnapshot)

Constants

const (
	GossipScoreThreshold             = -500
	PublishScoreThreshold            = -1000
	GraylistScoreThreshold           = -2500
	AcceptPXScoreThreshold           = 1000
	OpportunisticGraftScoreThreshold = 3.5
)

Functions

func FilecoinDHT

func FilecoinDHT(network string) protocol.ID

FilecoinDHT is creates a protocol for the filecoin DHT.

func NewGossipSub

func NewGossipSub(ctx context.Context,
	h host.Host,
	sk *ScoreKeeper,
	networkName string,
	drandSchedule map[abi.ChainEpoch]config.DrandEnum,
	bootNodes []peer.AddrInfo,
	bs bool,
	f3Config *vf3.Config,
) (*pubsub.PubSub, error)

func ParseAddresses

func ParseAddresses(ctx context.Context, addrs []string) ([]peer.AddrInfo, error)

ParseAddresses is a function that takes in a slice of string peer addresses (multiaddr + peerid) and returns a slice of properly constructed peers

Types

type Network

type Network struct {
	metrics.Reporter
	*Router
	// contains filtered or unexported fields
}

Network is a unified interface for dealing with libp2p

func New

func New(
	host host.Host,
	rawHost types.RawHost,
	router *Router,
	reporter metrics.Reporter,
) *Network

New returns a new Network

func (*Network) AgentVersion

func (network *Network) AgentVersion(ctx context.Context, p peer.ID) (string, error)

AgentVersion returns agent version for a given peer id

func (*Network) AutoNatStatus

func (network *Network) AutoNatStatus() (types.NatInfo, error)

AutoNatStatus return a struct with current NAT status and public dial address

func (*Network) Connect

func (network *Network) Connect(ctx context.Context, p peer.AddrInfo) error

Connect connects to peer at the given address. Does not retry.

func (*Network) Connectedness

func (network *Network) Connectedness(p peer.ID) (network2.Connectedness, error)

Connectedness returns a state signaling connection capabilities

func (*Network) Disconnect

func (network *Network) Disconnect(p peer.ID) error

Disconnect disconnect to peer at the given address

func (*Network) GetBandwidthStats

func (network *Network) GetBandwidthStats() metrics.Stats

GetBandwidthStats gets stats on the current bandwidth usage of the network

func (*Network) GetBandwidthStatsByPeer

func (network *Network) GetBandwidthStatsByPeer() (map[string]metrics.Stats, error)

GetBandwidthStatsByPeer returns statistics about the nodes bandwidth usage and current rate per peer

func (*Network) GetBandwidthStatsByProtocol

func (network *Network) GetBandwidthStatsByProtocol() (map[protocol.ID]metrics.Stats, error)

GetBandwidthStatsByProtocol returns statistics about the nodes bandwidth usage and current rate per protocol

func (*Network) GetPeerAddresses

func (network *Network) GetPeerAddresses() []ma.Multiaddr

GetPeerAddresses gets the current addresses of the node

func (*Network) GetPeerID

func (network *Network) GetPeerID() peer.ID

GetPeerID gets the current peer id from libp2p-host

func (*Network) PeerInfo

func (network *Network) PeerInfo(ctx context.Context, p peer.ID) (*types.ExtendedPeerInfo, error)

PeerInfo searches the peer info for a given peer id

func (*Network) Peers

func (network *Network) Peers(ctx context.Context) ([]peer.AddrInfo, error)

Peers lists peers currently available on the network

func (*Network) ProtectAdd

func (network *Network) ProtectAdd(peers []peer.ID) error

ProtectAdd protect peer at the given peers id

func (*Network) ProtectList

func (network *Network) ProtectList() ([]peer.ID, error)

ProtectList returns the peers that are protected

func (*Network) ProtectRemove

func (network *Network) ProtectRemove(peers []peer.ID) error

ProtectRemove unprotect peer at the given peers id

type Router

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

Router exposes the methods on the internal filecoin router that are needed by the system plumbing API.

func NewRouter

func NewRouter(r routing.Routing) *Router

NewRouter builds a new router.

func (*Router) FindPeer

func (r *Router) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)

FindPeer searches the libp2p router for a given peer id

func (*Router) FindProvidersAsync

func (r *Router) FindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo

FindProvidersAsync searches for and returns peers who are able to provide a given key.

func (*Router) GetClosestPeers

func (r *Router) GetClosestPeers(ctx context.Context, key string) ([]peer.ID, error)

GetClosestPeers returns a channel of the K closest peers to the given key, K is the 'K Bucket' parameter of the Kademlia DHT protocol.

type ScoreKeeper

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

func NewScoreKeeper

func NewScoreKeeper() *ScoreKeeper

func (*ScoreKeeper) Get

func (sk *ScoreKeeper) Get() map[peer.ID]*pubsub.PeerScoreSnapshot

func (*ScoreKeeper) Update

func (sk *ScoreKeeper) Update(scores map[peer.ID]*pubsub.PeerScoreSnapshot)