router

package

Go to main page

Versions in this module

v0

v0.11.0

Nov 17, 2022

Changes in this version

+ type FloodType int

+ const ClassicFlood

+ const TreeFlood

type Router

+ func (r *Router) DisableHopLimiting()

+ func (r *Router) DisableWakeupBroadcasts()

+ func (r *Router) EnableHopLimiting()

+ func (r *Router) EnableWakeupBroadcasts()

v0.10.0

Sep 27, 2022

Changes in this version

+ const BWReportingInterval

+ const PeerTypeBonjour

+ const PeerTypePipe

+ type RouterOption interface

+ type RouterOptionBlackhole bool

v0.9.0

Jul 8, 2022

Changes in this version

type Router

+ func (r *Router) NextHop(from net.Addr, frameType types.FrameType, dest net.Addr) net.Addr

v0.8.0

Apr 4, 2022

v0.7.0

Mar 30, 2022

Changes in this version

+ type FilterFn func(from types.PublicKey, f *types.Frame) bool

type Router

+ func (r *Router) InjectPacketFilter(fn FilterFn)

+ func (r *Router) ManholeHandler(w http.ResponseWriter, req *http.Request)

+ type TreeAnnouncementAction int64

+ const AcceptNewParent

+ const AcceptUpdate

+ const DropFrame

+ const InformPeerOfStrongerRoot

+ const SelectNewParent

+ const SelectNewParentWithWait

v0.6.0

Dec 13, 2021

Changes in this version

+ type ConnectionKeepalives bool

+ type ConnectionOption interface

+ type ConnectionPeerType int

+ type ConnectionPublicKey types.PublicKey

+ type ConnectionURI string

+ type ConnectionZone string

type PeerInfo

+ URI string

type Router

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

v0.5.0

Oct 21, 2021

Changes in this version

+ type NeighbourInfo struct

+ PathID types.VirtualSnakePathID

+ PublicKey types.PublicKey

type Router

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

v0.4.0

Oct 8, 2021

Changes in this version

+ const PeerKeepaliveInterval

+ const PeerKeepaliveTimeout

+ const TrafficBuffer

type Router

+ func (r *Router) SNEKPing(ctx context.Context, dst types.PublicKey) (time.Duration, error)

+ func (r *Router) ToggleDebug()

+ func (r *Router) TreePing(ctx context.Context, dst types.SwitchPorts) (time.Duration, error)

v0.3.0

Jun 8, 2021

Changes in this version

+ const MaxFrameSize

+ const MaxPayloadSize

type PeerInfo

+ RootPublicKey string

type Router

+ func (r *Router) Ascending() (*types.PublicKey, *types.VirtualSnakePathID)

+ func (r *Router) DHTInfo() (asc, desc *virtualSnakeNeighbour, ...)

+ func (r *Router) Descending() (*types.PublicKey, *types.VirtualSnakePathID)

v0.2.0

May 24, 2021

Changes in this version

type Peer

+ func (p *Peer) SeenCommonRootRecently() bool

type Router

+ func (r *Router) AllowImpreciseTraffic(allow bool)

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

v0.1.0

May 5, 2021

Changes in this version

+ const PeerTypeBluetooth

+ const PeerTypeMulticast

+ const PeerTypeRemote

+ const PortCount

+ const ProtoBufferSize

+ const TrafficBufferSize

+ type GreedyAddr struct

+ func (a *GreedyAddr) Network() string

+ func (a *GreedyAddr) String() string

+ type Peer struct

+ func (p *Peer) Coordinates() types.SwitchPorts

+ func (p *Peer) PublicKey() types.PublicKey

+ func (p *Peer) SeenRecently() bool

+ type PeerInfo struct

+ PeerType int

+ Port int

+ PublicKey string

+ Zone string

+ type Router struct

+ func NewRouter(log *log.Logger, id string, private ed25519.PrivateKey, ...) *Router

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

+ func (r *Router) AuthenticatedConnect(conn net.Conn, zone string, peertype int) (types.SwitchPortID, error)

+ func (r *Router) Close() error

+ func (r *Router) Connect(conn net.Conn, public types.PublicKey, zone string, peertype int) (types.SwitchPortID, error)

+ func (r *Router) Coords() types.SwitchPorts

+ func (r *Router) DHTSearch(ctx context.Context, pk ed25519.PublicKey, stopshort bool) (types.PublicKey, net.Addr, error)

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

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

+ func (r *Router) IsRoot() bool

+ func (r *Router) KnownNodes() []types.PublicKey

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

+ func (r *Router) Pathfind(ctx context.Context, addr net.Addr) (net.Addr, error)

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

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

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

+ 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) RootPublicKey() types.PublicKey

+ func (r *Router) SetConnectedCallback(f func(port types.SwitchPortID, publickey types.PublicKey, peertype int))

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

+ func (r *Router) SetDisconnectedCallback(...)

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

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

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

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

+ type Simulator interface

+ LookupCoords func(string) (types.SwitchPorts, error)

+ LookupNodeID func(types.SwitchPorts) (string, error)

+ LookupPublicKey func(types.PublicKey) (string, error)

+ ReportDeadLink func(types.PublicKey, types.PublicKey)

+ ReportDistance func(a, b string, l int64)

+ ReportNewLink func(net.Conn, types.PublicKey, types.PublicKey)

+ type SourceAddr struct

+ func (a *SourceAddr) Network() string

+ func (a *SourceAddr) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL