autopeering

Documentation

Index

• Constants
• Variables
• func BindAddress() string
• func Plugin() *node.Plugin
• func Selection() *selection.Protocol
• type NetConnMetric
  • func (nc *NetConnMetric) RXBytes() uint64
  • func (nc *NetConnMetric) ReadFromUDP(b []byte) (int, *net.UDPAddr, error)
  • func (nc *NetConnMetric) TXBytes() uint64
  • func (nc *NetConnMetric) WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)

Constants

const PluginName = "Autopeering"

PluginName is the name of the autopeering plugin.

Variables

var Parameters = struct {
	// Mana defines the config flag of mana in the autopeering.
	Mana bool `default:"true" usage:"enable/disable mana in the autopeering"`

	// R defines the config flag of R.
	R int `default:"40" usage:"R parameter"`

	// Ro defines the config flag of Ro.
	Ro float64 `default:"2." usage:"Ro parameter"`

	EnableGossipIntegration bool `default:"true" usage:"enable/disable autopeering for gossip layer"`
}{}

Parameters contains the configuration parameters used by the autopeering layer.

Functions

func BindAddress

func BindAddress() string

BindAddress returns the string form of the autopeering bind address.

func Plugin

func Plugin() *node.Plugin

Plugin gets the plugin instance.

func Selection

func Selection() *selection.Protocol

Selection returns the neighbor selection instance.

Types

type NetConnMetric

type NetConnMetric struct {
	*net.UDPConn
	// contains filtered or unexported fields
}

NetConnMetric is a wrapper of a UDPConn that keeps track of RX and TX bytes.

var (
	// Conn contains the network connection.
	Conn *NetConnMetric
)

func (*NetConnMetric) RXBytes

func (nc *NetConnMetric) RXBytes() uint64

RXBytes returns the RX bytes.

func (*NetConnMetric) ReadFromUDP

func (nc *NetConnMetric) ReadFromUDP(b []byte) (int, *net.UDPAddr, error)

ReadFromUDP acts like ReadFrom but returns a UDPAddr.

func (*NetConnMetric) TXBytes

func (nc *NetConnMetric) TXBytes() uint64

TXBytes returns the TX bytes.

func (*NetConnMetric) WriteToUDP

func (nc *NetConnMetric) WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)

WriteToUDP acts like WriteTo but takes a UDPAddr.