router

Documentation

Index

• Constants
• type ConnectionKeepalives
• type ConnectionOption
• type ConnectionPeerType
• type ConnectionPublicKey
• type ConnectionURI
• type ConnectionZone
• type NeighbourInfo
• type PeerInfo
• type Router
  • func NewRouter(logger *log.Logger, sk ed25519.PrivateKey, debug bool) *Router
  • func (r *Router) Addr() net.Addr
  • func (r *Router) Close() error
  • func (r *Router) Connect(conn net.Conn, options ...ConnectionOption) (types.SwitchPortID, error)
  • func (r *Router) Coords() types.Coordinates
  • func (r *Router) Disconnect(i types.SwitchPortID, err error)
  • func (r *Router) IsConnected(key types.PublicKey, zone string) bool
  • func (r *Router) LocalAddr() net.Addr
  • func (r *Router) PeerCount(peertype int) (count int)
  • func (r *Router) Peers() []PeerInfo
  • func (r *Router) Ping(ctx context.Context, a net.Addr) (uint16, time.Duration, error)
  • func (r *Router) PrivateKey() types.PrivateKey
  • func (r *Router) PublicKey() types.PublicKey
  • func (r *Router) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (r *Router) SetDeadline(t time.Time) error
  • func (r *Router) SetReadDeadline(t time.Time) error
  • func (r *Router) SetWriteDeadline(t time.Time) error
  • func (r *Router) Subscribe(ch chan<- events.Event)
  • func (r *Router) WriteTo(p []byte, addr net.Addr) (n int, err error)

Constants

const (
	PeerTypeMulticast int = iota
	PeerTypeBluetooth
	PeerTypeRemote
)

Types

type ConnectionKeepalives

type ConnectionKeepalives bool

type ConnectionOption

type ConnectionOption interface {
	// contains filtered or unexported methods
}

type ConnectionPeerType

type ConnectionPeerType int

type ConnectionPublicKey

type ConnectionPublicKey types.PublicKey

type ConnectionURI

type ConnectionURI string

type ConnectionZone

type ConnectionZone string

type NeighbourInfo

type NeighbourInfo struct {
	PublicKey types.PublicKey
	PathID    types.VirtualSnakePathID
}

type PeerInfo

type PeerInfo struct {
	URI       string
	Port      int
	PublicKey string
	PeerType  int
	Zone      string
}

type Router

type Router struct {
	phony.Inbox
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(logger *log.Logger, sk ed25519.PrivateKey, debug bool) *Router

func (*Router) Addr

func (r *Router) Addr() net.Addr

Addr returns the local address of the node in the form of a `types.PublicKey`.

func (*Router) Close

func (r *Router) Close() error

Close will stop the Pinecone node. Once this has been called, the node cannot be restarted or reused.

func (*Router) Connect

func (r *Router) Connect(conn net.Conn, options ...ConnectionOption) (types.SwitchPortID, error)

Connect takes a connection and attaches it to the switch as a peering. This function takes one or more ConnectionOptions to configure the peer. If no ConnectionPublicKey is specified, the connection will autonegotiate with the remote peer to exchange public keys and version/capability information.

func (*Router) Coords

func (r *Router) Coords() types.Coordinates

func (*Router) Disconnect

func (r *Router) Disconnect(i types.SwitchPortID, err error)

Disconnect will disconnect whatever is connected to the given port number on the Pinecone node. The peering will no longer be used and the underlying connection will be closed.

func (*Router) IsConnected

func (r *Router) IsConnected(key types.PublicKey, zone string) bool

IsConnected returns true if the node is connected within the given zone, or false otherwise.

func (*Router) LocalAddr

func (r *Router) LocalAddr() net.Addr

LocalAddr returns a net.Addr containing the public key of the node for SNEK routing.

func (*Router) PeerCount

func (r *Router) PeerCount(peertype int) (count int)

PeerCount returns the number of nodes that are directly connected to this Pinecone node.

func (*Router) Peers

func (r *Router) Peers() []PeerInfo

func (*Router) Ping

func (r *Router) Ping(ctx context.Context, a net.Addr) (uint16, time.Duration, error)

func (*Router) PrivateKey

func (r *Router) PrivateKey() types.PrivateKey

PrivateKey returns the private key of the node.

func (*Router) PublicKey

func (r *Router) PublicKey() types.PublicKey

PublicKey returns the public key of the node.

func (*Router) ReadFrom

func (r *Router) ReadFrom(p []byte) (n int, addr net.Addr, err error)

ReadFrom reads the next packet that was delivered to this node over the Pinecone network. Only traffic frames will be returned here (not protocol frames). The returned address will either be a `types.PublicKey` (if the frame was delivered using SNEK routing) or `types.Coordinates` (if the frame was delivered using tree routing).

func (*Router) SetDeadline

func (r *Router) SetDeadline(t time.Time) error

SetDeadline is not implemented.

func (*Router) SetReadDeadline

func (r *Router) SetReadDeadline(t time.Time) error

SetReadDeadline is not implemented.

func (*Router) SetWriteDeadline

func (r *Router) SetWriteDeadline(t time.Time) error

SetWriteDeadline is not implemented.

func (*Router) Subscribe

func (r *Router) Subscribe(ch chan<- events.Event)

Subscribe registers a subscriber to this node's events

func (*Router) WriteTo

func (r *Router) WriteTo(p []byte, addr net.Addr) (n int, err error)

WriteTo sends a packet into the Pinecone network. The packet will be sent as a traffic packet. The supplied net.Addr will dictate the method used to route the packet — the address should be a `types.PublicKey` for SNEK routing or `types.Coordinates` for tree routing. Supplying an unsupported address type will result in a `*net.AddrError` being returned.