net

Documentation

Index

• Variables
• func GetAddresses(protocol string, l net.Listener) []string
• func GetLocalPeerAddresses(port int) ([]string, error)
• func Read(conn *Connection) (*object.Object, error)
• func WithEventBus(k eventbus.Eventbus) func(*network)
• func WithKeychain(k keychain.Keychain) func(*network)
• func Write(o object.Object, conn *Connection) error
• type Connection
  • func (c *Connection) Close() error
  • func (c *Connection) LocalAddr() string
  • func (c *Connection) RemoteAddr() string
• type Handshake
  • func (hs *Handshake) Handle() MiddlewareHandler
• type HandshakeAck
  • func (e *HandshakeAck) FromObject(o object.Object) error
  • func (e HandshakeAck) GetSchema() *object.SchemaObject
  • func (e HandshakeAck) GetType() string
  • func (e HandshakeAck) ToObject() object.Object
• type HandshakeSyn
  • func (e *HandshakeSyn) FromObject(o object.Object) error
  • func (e HandshakeSyn) GetSchema() *object.SchemaObject
  • func (e HandshakeSyn) GetType() string
  • func (e HandshakeSyn) ToObject() object.Object
• type HandshakeSynAck
  • func (e *HandshakeSynAck) FromObject(o object.Object) error
  • func (e HandshakeSynAck) GetSchema() *object.SchemaObject
  • func (e HandshakeSynAck) GetType() string
  • func (e HandshakeSynAck) ToObject() object.Object
• type Listener
• type Middleware
• type MiddlewareHandler
• type Network
  • func New(opts ...Option) Network
• type Option
• type 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")
	// ErrMissingSignature is when the signature is missing
	ErrMissingSignature = errors.New("signature missing")
	// ErrAllAddressesBlacklisted all peer's addresses are currently blacklisted
	ErrAllAddressesBlacklisted = errors.New("all addresses blacklisted")
)

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

)

var (
	DefaultNetwork = New(
		WithEventBus(eventbus.DefaultEventbus),
		WithKeychain(keychain.DefaultKeychain),
	)
)

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 Read

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

func WithEventBus

func WithEventBus(k eventbus.Eventbus) func(*network)

WithEventBus overrides the default eventbus for the network.

func WithKeychain

func WithKeychain(k keychain.Keychain) func(*network)

WithKeychain overrides the default keychain for the network.

func Write

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

Types

type Connection

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

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) LocalAddr

func (c *Connection) LocalAddr() string

func (*Connection) RemoteAddr

func (c *Connection) RemoteAddr() string

type Handshake

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

Handshake middleware

func (*Handshake) Handle

func (hs *Handshake) Handle() MiddlewareHandler

Handle incoming and outgoing connections TODO needs to be able to handle both server and client interactions

type HandshakeAck

type HandshakeAck struct {
	Stream     object.Hash
	Parents    []object.Hash
	Owners     []crypto.PublicKey
	Policy     object.Policy
	Signatures []object.Signature
	Nonce      string
	// contains filtered or unexported fields
}

func (*HandshakeAck) FromObject

func (e *HandshakeAck) FromObject(o object.Object) error

func (HandshakeAck) GetSchema

func (e HandshakeAck) GetSchema() *object.SchemaObject

func (HandshakeAck) GetType

func (e HandshakeAck) GetType() string

func (HandshakeAck) ToObject

func (e HandshakeAck) ToObject() object.Object

type HandshakeSyn

type HandshakeSyn struct {
	Stream     object.Hash
	Parents    []object.Hash
	Owners     []crypto.PublicKey
	Policy     object.Policy
	Signatures []object.Signature
	Nonce      string
	// contains filtered or unexported fields
}

func (*HandshakeSyn) FromObject

func (e *HandshakeSyn) FromObject(o object.Object) error

func (HandshakeSyn) GetSchema

func (e HandshakeSyn) GetSchema() *object.SchemaObject

func (HandshakeSyn) GetType

func (e HandshakeSyn) GetType() string

func (HandshakeSyn) ToObject

func (e HandshakeSyn) ToObject() object.Object

type HandshakeSynAck

type HandshakeSynAck struct {
	Stream     object.Hash
	Parents    []object.Hash
	Owners     []crypto.PublicKey
	Policy     object.Policy
	Signatures []object.Signature
	Nonce      string
	// contains filtered or unexported fields
}

func (*HandshakeSynAck) FromObject

func (e *HandshakeSynAck) FromObject(o object.Object) error

func (HandshakeSynAck) GetSchema

func (e HandshakeSynAck) GetSchema() *object.SchemaObject

func (HandshakeSynAck) GetType

func (e HandshakeSynAck) GetType() string

func (HandshakeSynAck) ToObject

func (e HandshakeSynAck) ToObject() object.Object

type Listener

type Listener interface {
	Close() error
	Addresses() []string
}

type Middleware

type Middleware interface {
	Handle() MiddlewareHandler
}

Middleware defines a middleware interface

type MiddlewareHandler

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

MiddlewareHandler defines a middleware handler

type Network

type Network interface {
	Dial(
		ctx context.Context,
		peer *peer.Peer,
	) (*Connection, error)
	Listen(
		ctx context.Context,
		bindAddress string,
	) (Listener, error)
	Accept() (*Connection, error)
	Addresses() []string
}

Network interface

func New

func New(opts ...Option) Network

New creates a new p2p network

type Option

type Option func(*network)

Option for customizing a new network

type Transport

type Transport interface {
	Dial(
		ctx context.Context,
		address string,
	) (*Connection, error)
	Listen(
		ctx context.Context,
		bindAddress string,
		key crypto.PrivateKey,
	) (net.Listener, error)
}