net

Documentation

Index

• Variables
• func GetAddresses(protocol string, l net.Listener) []string
• func GetLocalPeerAddresses(port int) ([]string, error)
• func RandStringBytesMaskImprSrc(n int) string
• func Read(conn *Connection) (*object.Object, error)
• func SendConnectionEvent(outgoing bool)
• func SendEvent(event telemetry.Collectable)
• func SendObjectEvent(direction string, contentType string, objectSize int)
• func Write(o *object.Object, conn *Connection) error
• type Addresses
  • func NewAddresses() Addresses
  • func (a Addresses) Add(addresses ...string)
  • func (a Addresses) Blacklist(addresses ...string)
  • func (a Addresses) List() []string
  • func (a Addresses) Remove(addresses ...string)
• type Connection
  • func (c *Connection) Close() error
• type LocalInfo
  • func NewLocalInfo(hostname string, key *crypto.PrivateKey) (*LocalInfo, error)
  • func (l *LocalInfo) AddAddress(addrs ...string)
  • func (l *LocalInfo) AddContentHash(hashes ...string)
  • func (l *LocalInfo) AddIdentityKey(identityKey *crypto.PrivateKey) error
  • func (l *LocalInfo) GetFingerprint() crypto.Fingerprint
  • func (l *LocalInfo) GetHostname() string
  • func (l *LocalInfo) GetPeerInfo() *peer.PeerInfo
  • func (l *LocalInfo) GetPeerKey() *crypto.PrivateKey
  • func (l *LocalInfo) RemoveContentHash(hashes ...string)
• type Middleware
• type MiddlewareHandler
• type Network
  • func New(discover discovery.Discoverer, local *LocalInfo) (Network, error)
• type Option
  • func WithLocalDiscoveryOnly() Option
• type Options
• type Transport
  • func NewHTTPTransport(local *LocalInfo, address string) Transport
  • func NewTCPTransport(local *LocalInfo, address string) Transport

Variables

var (
	// ErrAllAddressesFailed for when a peer cannot be dialed
	ErrAllAddressesFailed = errors.New("all addresses failed to dial")
	// ErrNoAddresses for when a peer has no addresses
	ErrNoAddresses = errors.New("no addresses")
	// ErrNotForUs object is not meant for us
	ErrNotForUs = errors.New("object not for us")
	// ErrMissingKey when a key is not passed
	ErrMissingKey = errors.New("missing key")
	// ErrECDSAPrivateKeyRequired when a key is not an ECDSA key
	ErrECDSAPrivateKeyRequired = errors.New(
		"network currently requires an ecdsa private key")
	// ErrNonce is when the nonce does not match
	ErrNonce = errors.New("nonce does not match")
)

var (
	BindLocal = false // TODO(geoah) refactor to remove global

)

var (
	UseUPNP = false
)

Functions

func GetAddresses

func GetAddresses(protocol string, l net.Listener) []string

GetAddresses returns the addresses the transport is listening to

func GetLocalPeerAddresses

func GetLocalPeerAddresses(port int) ([]string, error)

GetLocalPeerAddresses returns the addresses TCP can listen to on the local machine

func RandStringBytesMaskImprSrc

func RandStringBytesMaskImprSrc(n int) string

RandStringBytesMaskImprSrc returns a random string given a length

func Read

func Read(conn *Connection) (*object.Object, error)

func SendConnectionEvent

func SendConnectionEvent(outgoing bool)

SendConnectionEvent sends a connection event

func SendEvent

func SendEvent(event telemetry.Collectable)

SendEvent sends an event

func SendObjectEvent

func SendObjectEvent(direction string, contentType string, objectSize int)

SendObjectEvent sends a connection event

func Write

func Write(o *object.Object, conn *Connection) error

Types

type Addresses

type Addresses map[string]bool

func NewAddresses

func NewAddresses() Addresses

func (Addresses) Add

func (a Addresses) Add(addresses ...string)

func (Addresses) Blacklist

func (a Addresses) Blacklist(addresses ...string)

func (Addresses) List

func (a Addresses) List() []string

func (Addresses) Remove

func (a Addresses) Remove(addresses ...string)

type Connection

type Connection struct {
	RemotePeerKey *crypto.PublicKey
	IsIncoming    bool
	// contains filtered or unexported fields
}

func (*Connection) Close

func (c *Connection) Close() error

type LocalInfo

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

func NewLocalInfo

func NewLocalInfo(hostname string, key *crypto.PrivateKey) (
	*LocalInfo, error)

func (*LocalInfo) AddAddress

func (l *LocalInfo) AddAddress(addrs ...string)

func (*LocalInfo) AddContentHash

func (l *LocalInfo) AddContentHash(hashes ...string)

AddContentHash that should be published with the peer info

func (*LocalInfo) AddIdentityKey

func (l *LocalInfo) AddIdentityKey(identityKey *crypto.PrivateKey) error

func (*LocalInfo) GetFingerprint

func (l *LocalInfo) GetFingerprint() crypto.Fingerprint

func (*LocalInfo) GetHostname

func (l *LocalInfo) GetHostname() string

func (*LocalInfo) GetPeerInfo

func (l *LocalInfo) GetPeerInfo() *peer.PeerInfo

GetPeerInfo returns the local peer info

func (*LocalInfo) GetPeerKey

func (l *LocalInfo) GetPeerKey() *crypto.PrivateKey

func (*LocalInfo) RemoveContentHash

func (l *LocalInfo) RemoveContentHash(hashes ...string)

RemoveContentHash from the peer info

type Middleware

type Middleware interface {
	Handle() MiddlewareHandler
}

Middleware ...

type MiddlewareHandler

type MiddlewareHandler func(ctx context.Context,
	conn *Connection) (*Connection, error)

MiddlewareHandler ...

type Network

type Network interface {
	Dial(ctx context.Context, address string, options ...Option) (*Connection, error)
	Listen(ctx context.Context) (chan *Connection, error)

	AddMiddleware(handler MiddlewareHandler)
	AddTransport(tag string, tsp Transport)
}

Network interface

func New

func New(discover discovery.Discoverer, local *LocalInfo) (Network, error)

New creates a new p2p network using an address book

type Option

type Option func(*Options)

func WithLocalDiscoveryOnly

func WithLocalDiscoveryOnly() Option

type Options

type Options struct {
	LocalDiscoveryOnly bool
}

Options (mostly) for Dial()

type Transport

type Transport interface {
	Dial(ctx context.Context, address string) (*Connection, error)
	Listen(ctx context.Context) (chan *Connection, error)
}

func NewHTTPTransport

func NewHTTPTransport(
	local *LocalInfo,
	address string,
) Transport

func NewTCPTransport

func NewTCPTransport(
	local *LocalInfo,
	address string,
) Transport